NATSQueuedIterator overview
Added in v0.1.0
Table of contents
models
NATSQueuedIterator (interface)
Represents a NATS QueuedIterator wrapper with Effect methods
Signature
export interface NATSQueuedIterator<T, E> {
readonly [TypeId]: TypeId
readonly stop: (err?: Error) => Effect.Effect<void>
readonly getProcessed: Effect.Effect<number>
readonly getPending: Effect.Effect<number>
readonly getReceived: Effect.Effect<number>
readonly stream: Stream.Stream<T, E, never>
/** @internal */
readonly iterator: NATS.QueuedIterator<T>
}
Added in v0.1.0
type ids
TypeId
Signature
export declare const TypeId: typeof TypeId
Added in v0.1.0
TypeId (type alias)
Signature
export type TypeId = typeof TypeId
Added in v0.1.0