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

last()

Emits the last value when upstream completes (no emission until END).

Signature

ts

function last<A>(): StoreOperator<A, A | undefined>

Returns

StoreOperator<A, A | undefined> — Tier 1.

Pager

Previous pagefirst()

Next pagefind()

Released under the MIT License.