Interface EventStreamMarshallerSerFn<StreamType>

Type Parameters

• StreamType

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

  Type Parameters

  • T

  Parameters

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

  Returns StreamType