@epikodelabs/streamix / src/public-api
src/public-api
Classes
Interfaces
- AtomOptions
- Atom
- Readable
- Writable
- Scheduler
- AtomFromIteratorOptions
- AtomExpr
- DerivedExpr
- PipeExpr
- FlowExpr
- RootScope
- Scope
- ResolutionContext
- RegistrationOptions
- Container
- 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
- AtomAccessor
- ScopeOfConfig
- ScopePublicValue
- ScopeSetupResult
- ScopeSetupSelf
- ScopeSetupSelfFromConfig
- ScopeOptions
- ScopeReservedAtoms
- UnwrapScopeValuesFromConfig
- ScopeAtoms
- ScopeReturn
- ScopeReturnFromConfig
- ScopeConfig
- Subscription
- Lifetime
- Factory
- Token
- TokenValue
- ExpandOptions
- GroupItem
- CyclicBufferMode
- ReleaseFn
- RunnerEvent
- AsyncIteratorYieldResult
- AsyncIteratorResult
- AsyncPushable
- SharedSourceMode
- SharedSourceOptions
Variables
Functions
- setScheduler
- getScheduler
- 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
- resolveMode
- method
- getCurrentScope
- getScopeMode
- setCurrentScope
- provide
- inject
- injectOptional
- 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
- createContainer
- resetGlobalContainer
- registerMany
- createModule
- createToken
- 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