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

JetStreamStoredMessage overview

Added in v0.1.0


Table of contents


models

JetStreamStoredMessage (interface)

Represents a NATS JetStream Stored Message

Signature

export interface JetStreamStoredMessage {
  readonly [TypeId]: TypeId
  readonly subject: string
  readonly seq: number
  readonly header: NATSCore.MsgHdrs
  readonly data: Uint8Array
  readonly time: Date
  readonly timestamp: string
  readonly lastSequence: number
  readonly pending: number
  readonly json: <T>(
    ...params: Parameters<JetStream.StoredMsg["json"]>
  ) => Effect.Effect<T, NATSError.JetStreamStoredMessageError>
  readonly string: Effect.Effect<string, NATSError.JetStreamStoredMessageError>

  /** @internal */
  readonly msg: JetStream.StoredMsg
}

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