Interface EventStreamMarshallerDeserFn<StreamType>
Hierarchy
- EventStreamMarshallerDeserFn
- EventStreamMarshallerDeserFn<T>(body: StreamType, deserializer: ((input: Record<string, Message>) => Promise<T>)): AsyncIterable<T>
-
Parameters
-
body: StreamType
-
deserializer: ((input: Record<string, Message>) => Promise<T>)
-
- (input: Record<string, Message>): Promise<T>
-
Returns Promise<T>
Returns AsyncIterable<T>
A function which deserializes binary event stream message into modeled shape.