@epikodelabs/streamix
@epikodelabs/streamix
Interfaces
Type Aliases
- PipeStreamHookContext
- PipeStreamHookResult
- StreamRuntimeHooks
- IteratorMetaKind
- IteratorMetaTag
- MaybePromise
- Operator
- Receiver
- StrictReceiver
- Stream
- Subscription
- ExpandOptions
- GroupItem
- ReleaseFn
- BehaviorSubject
- QueueItem
- ReplaySubject
- Subject
Variables
Functions
- nextEmissionStamp
- getCurrentEmissionStamp
- withEmissionStamp
- setIteratorEmissionStamp
- getIteratorEmissionStamp
- registerRuntimeHooks
- unregisterRuntimeHooks
- getRuntimeHooks
- setIteratorMeta
- getIteratorMeta
- setValueMeta
- getValueMeta
- isWrappedPrimitive
- unwrapPrimitive
- applyPipeStreamHooks
- generateStreamId
- generateSubscriptionId
- isPromiseLike
- NEXT
- createOperator
- createReceiver
- isStreamLike
- createStream
- pipeSourceThrough
- createSubscription
- eachValueFrom
- firstValueFrom
- fromAny
- lastValueFrom
- 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
- createLock
- createQueue
- enqueueMicrotask
- runInMicrotask
- createSemaphore
- empty
- combineLatest
- concat
- defer
- forkJoin
- from
- fromEvent
- fromPromise
- iif
- interval
- loop
- merge
- of
- race
- range
- retry
- timer
- zip
- createBehaviorSubject
- createTryCommit
- createRegister
- createAsyncIterator
- createReplaySubject
- createSubject