Struct ChunkStream 

pub struct ChunkStream { /* private fields */ }

Active /chunks/stream upload session. Open one via FileApi::chunks_stream.

Each Self::send_chunk sends one binary frame and awaits the server’s 0x00 ack before returning. The session remains usable until Self::close (or until dropped).

Implementations

impl ChunkStream

pub async fn send_chunk(&mut self, chunk: impl Into<Bytes>) -> Result<(), Error>

Send one chunk (span || payload framing per Bee’s content- addressed chunk format) and await the server ack.

Returns Error::Argument if the websocket has already been closed or if the server replied with anything other than the single-byte 0 ack.

pub async fn close(self) -> Result<(), Error>

Close the websocket gracefully. Idempotent. Errors during close are swallowed — the socket is dropped regardless.

Trait Implementations

impl Debug for ChunkStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.