@epikodelabs/streamix / src/public-api
src/public-api
Classes
Interfaces
- AtomOptions
- Atom
- Readable
- DependencySource
- Writable
- Scheduler
- AtomFromIteratorOptions
- FlowOptions
- AtomExpr
- DerivedExpr
- PipeExpr
- FlowExpr
- IterateOptions
- RootScope
- Scope
- ForkOption
- CyclicBuffer
- SimpleLock
- Semaphore
- AsyncCoordinatorOptions
- AsyncCoordinator
- QueueItem
- PendingError
Type Aliases
- AtomValue
- DerivedScope
- SyncOnly
- OperatorInput
- OperatorOutput
- ComposeResult
- MaybePromise
- Operator
- PipeResult
- PipeInput
- WidenValue
- ScopeInstance
- UnwrapScopeValues
- AtomOf
- AtomValueOf
- ScopeAtoms
- ScopeOfConfig
- ScopePublicValue
- ScopeSetupResult
- ScopeSetupSelf
- ScopeSetupSelfFromConfig
- ScopeReservedAtoms
- UnwrapScopeValuesFromConfig
- ScopeAtomGraph
- ScopeReturn
- ScopeReturnFromConfig
- ScopeConfig
- Subscription
- ExpandOptions
- GroupItem
- CyclicBufferMode
- ReleaseFn
- RunnerEvent
- AsyncIteratorYieldResult
- AsyncIteratorResult
- AsyncPushable
- SharedSourceMode
- SharedSourceOptions
Variables
Functions
- setScheduler
- getScheduler
- transaction
- getCurrentFormulaContext
- trackDependencies
- asReadable
- normalizeError
- onAtomDirtyChange
- onAtomEmit
- atomFromIterator
- flow
- atom
- derived
- createTestScheduler
- createTestEnvironment
- compose
- isAtomExpr
- isDerivedExpr
- isPipeExpr
- isFlowExpr
- atomExpr
- derivedExpr
- pipeExpr
- flowExpr
- isExprMarker
- iterate
- isPromiseLike
- NEXT
- isOperator
- createOperator
- createPushOperator
- toAsyncIterable
- pipe
- getGlobalScope
- isScope
- method
- get
- set
- getCurrentScope
- setCurrentScope
- scope
- disposeScope
- registerWithCurrentScope
- markAtomAsEmitted
- hasAtomEmitted
- createSubscription
- empty
- addListener
- combineLatest
- commit
- concat
- defer
- firstValueFrom
- forkJoin
- from
- iif
- interval
- lastValueFrom
- loop
- merge
- of
- race
- range
- retry
- timer
- zip
- audit
- buffer
- bufferCount
- bufferUntil
- bufferWhile
- catchError
- concatMap
- debounce
- defaultIfEmpty
- delay
- delayUntil
- delayWhile
- distinctUntilChanged
- distinctUntilKeyChanged
- endWith
- exhaustMap
- expand
- filter
- finalize
- first
- fork
- groupBy
- ignoreElements
- last
- map
- mergeMap
- observeOn
- partition
- reduce
- sample
- scan
- select
- share
- shareReplay
- skip
- skipUntil
- skipWhile
- slidingPair
- startWith
- switchMap
- take
- takeUntil
- takeWhile
- tap
- throttle
- throwError
- toArray
- withLatestFrom
- cyclicBuffer
- createLock
- createQueue
- createSemaphore
- createAsyncCoordinator
- getIterator
- raceNext
- syncPull
- asyncPull
- pushValue
- pushComplete
- pushError
- isAtomLike
- isAtom
- isAsyncIterable
- isIterable
- createAsyncIterator
- createAsyncPushable
- createSharedSource