Module common

Functions

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