Interface EventStreamMarshallerDeserFn<StreamType>

Callable

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

• public

  A function which deserializes binary event stream message into modeled shape.

  Type parameters

  • T

  Parameters

  • body: StreamType

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

    • • (input: Record<string, Message>): Promise<T>

      • Parameters

        • input: Record<string, Message>

        Returns Promise<T>

  Returns AsyncIterable<T>