Interface EventStreamMarshallerSerFn<StreamType>

Callable

• __call<T>(input: AsyncIterable<T>, serializer: (event: T) => Message): StreamType

• public

  A function that serializes modeled shape into binary stream message.

  Type parameters

  • T

  Parameters

  • input: AsyncIterable<T>

  • serializer: (event: T) => Message

    • • (event: T): Message

      • Parameters

        • event: T

        Returns Message

  Returns StreamType