Module common

Functions

into_chunk_stream 🔒

Utility function to convert SourceMessage stream (got from specific connector’s SplitReader) into [StreamChunk] stream (by invoking ByteStreamSourceParserImpl).