risingwave_connector::source::filesystem::s3::source

Module split_stream

source

Functionsยง

  • split_stream ๐Ÿ”’
    This function splits a byte stream by the newline separator โ€œ(\r)\nโ€ into a message stream. It can be difficult to split and compute offsets correctly when the bytes are received in chunks. There are two cases to consider: