@epikodelabs/streamix / src/public-api
src/public-api
Classes
Interfaces
- AtomOptions
- Atom
- 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
- DefinedInput
- Subscription
- Lifetime
- Factory
- Token
- TokenValue
- ExpandOptions
- GroupItem
- CyclicBufferMode
- ReleaseFn
- RunnerEvent
- AsyncIteratorYieldResult
- AsyncIteratorResult
- AsyncPushable
- SharedSourceMode
- SharedSourceOptions
Variables
Functions
- setScheduler
- getScheduler
- getCurrentFormulaContext
- trackDependencies
- normalizeError
- 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
- combineLatest
- commit
- concat
- defer
- firstValueFrom
- forkJoin
- from
- iif
- interval
- lastValueFrom
- listen
- 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