unframedBy

Adapts a stream of byte chunks (e.g. from an L2CAP CoC incoming flow) into a stream of complete framed payloads.

Each collection allocates its own fresh Unframer via framer, so the same Framer instance is safe to share across multiple collectors.

If the source flow completes while bytes are still buffered, the partial tail is silently dropped. Inspect the source's terminal state or wire your own diagnostics if that matters.

A malformed length prefix throws FrameTooLargeException downstream, which cancels the flow. Wrap with .catch { } to recover.