Framing

line

rxsci.framing.line.frame()

Frames a Observable of text item to lines

The source must be an Observable.

rxsci.framing.line.unframe()

Unframes a Observable of text delimited by new-line

The source must be an Observable.

length prefix

rxsci.framing.length_prefix.frame(prefix_size=4, byteorder='little')

Frames an Observable of byte items to a len prefixed streaming format

The source must be an Observable.

rxsci.framing.length_prefix.unframe(prefix_size=4, byteorder='little')

unframe a Observable of bytes from a len prefixed streaming format

The source must be an Observable.