Module common

Functions

into_chunk_stream 🔒

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