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

empty()

Completes immediately with no DATA (Tier 2).

Signature

ts

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

Returns

ProducerStore<T>

Pager

Previous pageof()

Next pagenever()

Released under the MIT License.

empty() ​

Signature ​

Returns ​

empty()

Signature

Returns