@epikodelabs/streamix
@epikodelabs/streamix
Classes
Interfaces
Type Aliases
- MaybePromise
- DroppedResult
- Operator
- Receiver
- StrictReceiver
- Stream
- Subscription
- ExpandOptions
- GroupItem
- ReleaseFn
- BehaviorSubject
- ReplaySubject
- Subject
- RunnerEvent
- AsyncIteratorYieldResult
- AsyncIteratorResult
- AsyncPushable
Variables
Functions
- isPromiseLike
- NEXT
- DROPPED
- isDroppedResult
- nextSourceResult
- createOperator
- createPushOperator
- 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
- createSemaphore
- empty
- combineLatest
- concat
- defer
- forkJoin
- from
- fromEvent
- fromPromise
- iif
- interval
- loop
- merge
- of
- race
- range
- retry
- timer
- zip
- createBehaviorSubject
- createReplaySubject
- createSubject
- createAsyncCoordinator
- syncPull
- asyncPull
- pushValue
- pushComplete
- pushError
- pushDropped
- createAsyncIterator
- createAsyncPushable