Interface EventStreamMarshallerDeserFn<StreamType>

Type Parameters

• StreamType

• EventStreamMarshallerDeserFn<T>(
      body: StreamType,
      deserializer: (input: Record<string, Message>) => Promise<T>,
  ): AsyncIterable<T>

  Type Parameters

  • T

  Parameters

  • body: StreamType
  • deserializer: (input: Record<string, Message>) => Promise<T>

  Returns AsyncIterable<T>