Skip to main content Link Search Menu Expand Document (external link)
effect-messaging

JetStreamLister overview

Added in v0.1.0

Table of contents

models

JetStreamLister (interface)

Represents a NATS JetStream Lister wrapper with Effect methods

Signature

export interface JetStreamLister<T, E> {
  readonly [TypeId]: TypeId
  readonly next: () => Effect.Effect<Array<T>>
  readonly stream: Stream.Stream<T, E, never>

  /** @internal */
  readonly lister: JetStream.Lister<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