File tree Expand file tree Collapse file tree 1 file changed +20
-2
lines changed
Expand file tree Collapse file tree 1 file changed +20
-2
lines changed Original file line number Diff line number Diff line change @@ -87,9 +87,27 @@ export interface EventStreamSerdeContext {
8787 eventStreamMarshaller : EventStreamMarshaller ;
8888}
8989
90+ /**
91+ * A function which deserializes binary event stream message into modeled shape.
92+ */
93+ export interface EventStreamMarshallerDeserFn {
94+ < T > ( body : any , deserializer : ( input : Record < string , Message > ) => Promise < T > ) : AsyncIterable < T > ;
95+ }
96+
97+ /**
98+ * A function that serializes modeled shape into binary stream message.
99+ */
100+ export interface EventStreamMarshallerSerFn {
101+ < T > ( input : AsyncIterable < T > , serializer : ( event : T ) => Message ) : any ;
102+ }
103+
104+ /**
105+ * An interface which provides functions for serializing and deserializing binary event stream
106+ * to/from corresponsing modeled shape.
107+ */
90108export interface EventStreamMarshaller {
91- deserialize : ( body : any , deserializer : ( input : Record < string , Message > ) => any ) => AsyncIterable < any > ;
92- serialize : ( input : AsyncIterable < any > , serializer : ( event : any ) => Message ) => any ;
109+ deserialize : EventStreamMarshallerDeserFn ;
110+ serialize : EventStreamMarshallerSerFn ;
93111}
94112
95113export interface EventStreamRequestSigner {
You can’t perform that action at this time.
0 commit comments