AsyncCollector: For each input streaming record, an AsyncCollector will be created and passed into user's callback to get the async i/o result.

Codec is the interface for transport codecs to convert between transport specific payloads and the Message interface.

------------------------------------------------------------------------ common ------------------------------------------------------------------------.

Sink.

------------------------------------------------------------------------ sink function ------------------------------------------------------------------------.

------------------------------------------------------------------------ SinkAsyncTransport ------------------------------------------------------------------------.

Client interface defines the runtime contract the Message client supports.

Source.

Client interface defines the runtime contract the Message client supports.

------------------------------------------------------------------------ source function ------------------------------------------------------------------------.

------------------------------------------------------------------------ SourceTransport ------------------------------------------------------------------------.

------------------------------------------------------------------------ check pointed ------------------------------------------------------------------------.

type FunctionInitializationContext = ManagedInitializationContext.