Skip to content

callbag-recharge

Main Navigation Guide API Recipes Comparisons Edge AI Demos Architecture Blog

Sidebar Navigation

Core

state()

derived()

dynamicDerived()

effect()

producer()

operator()

pipe()

batch()

teardown()

subscribe()

Inspector

Protocol & Lifecycle

Extra

All Operators Reference

fromAny()

fromIter()

fromAsyncIter()

fromEvent()

fromPromise()

fromObs()

of()

empty()

never()

throwError()

interval()

fromCron()

fromTrigger()

route()

pipeRaw()

map()

filter()

scan()

take()

skip()

first()

last()

find()

elementAt()

distinctUntilChanged()

startWith()

pairwise()

takeUntil()

takeWhile()

withLatestFrom()

partition()

switchMap()

concatMap()

exhaustMap()

flat()

share()

tap()

remember()

cached()

debounce()

throttle()

delay()

merge()

combine()

concat()

race()

buffer()

bufferCount()

bufferTime()

window()

windowCount()

windowTime()

sample()

audit()

timeout()

reduce()

toArray()

groupBy()

rescue()

repeat()

forEach()

pausable()

subject()

wrap()

Data Structures

reactiveLog()

compaction()

reactiveMap()

reactiveIndex()

reactiveList()

pubsub()

Orchestration

pipeline()

task()

taskState()

branch()

approval()

gate()

forEach()

onFailure()

wait()

join()

sensor()

loop()

subPipeline()

executionLog()

pipelineRunner()

checkpoint()

fromCron()

fromTrigger()

route()

toMermaid()

toD2()

dagLayout()

workflowNode()

Messaging

topic()

subscription()

jobQueue()

jobFlow()

repeatPublish()

Memory

collection()

memoryNode()

decay()

vectorIndex()

Adapters

fromLLM()

fromMCP()

fromHTTP()

fromWebSocket()

fromWebhook()

toSSE()

Worker

workerBridge()

workerSelf()

withConnectionStatus()

Utils

withStatus()

withBreaker()

withSchema()

withMeta()

retry()

track()

dag()

cascadingCache()

tieredStorage()

keyedAsync()

namespace()

transaction()

priorityQueue()

tokenTracker()

autoSave()

contentStats()

cursorInfo()

cancellableStream()

stateMachine()

circuitBreaker()

backoff()

Patterns

chatStream()

agentLoop()

memoryStore()

createStore()

formField()

textEditor()

undoRedo()

pagination()

toolCallState()

hybridRoute()

commandBus()

selection()

rateLimiter()

textBuffer()

Framework Bindings

useSubscribeRecord() (Vue)

Vue (useStore, useSubscribe)

React (useStore, useSubscribe)

Svelte (useSubscribe)

Solid (useSubscribe)

Zustand compat

Jotai compat

Nanostores compat

TC39 Signals compat

On this page

never()

Inert source: never emits, completes, or errors (Tier 2).

Signature

ts

function never<T = never>(): ProducerStore<T>

Returns

ProducerStore<T>

Pager

Previous pageempty()

Next pagethrowError()

Released under the MIT License.