Struct fastly::body::StreamingBody

pub struct StreamingBody { /* fields omitted */ }

A streaming HTTP body that can be written to, or appended to from another body.

The interface to this type is very similar to Body, however it is write-only, and can only be created as a result of calling ResponseExt::send_downstream_streaming() or RequestExt::send_async_streaming().

The most efficient way to write the body is through the Write implementation. Writes are buffered, but calling Write::flush() will flush the buffer and cause a new chunk to be written to the downstream client.

A streaming body will be automatically closed when it goes out of scope, or when it is passed to drop().

Implementations

impl StreamingBody

pub fn append(&mut self, other: Body)

Append a body onto the end of this streaming body.

pub fn write_bytes(&mut self, bytes: &[u8]) -> usize

Write a slice of bytes to the end of this StreamingBody.

This function returns the number of bytes written.

let mut streaming_body = resp.send_downstream_streaming();
streaming_body.write_bytes(&[0, 1, 2, 3]);

pub fn write_str(&mut self, string: &str) -> usize

Write a string slice to the end of this StreamingBody.

This function returns the number of bytes written.

let mut streaming_body = resp.send_downstream_streaming();
streaming_body.write_str("woof woof");

Trait Implementations

impl From<StreamingBodyHandle> for StreamingBody

fn from(handle: StreamingBodyHandle) -> Self

Performs the conversion.

impl Write for StreamingBody

fn write(&mut self, buf: &[u8]) -> Result<usize>

Write a buffer into this writer, returning how many bytes were written.

fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize>

Like write, except that it writes from a slice of buffers.

fn flush(&mut self) -> Result<()>

Flush this output stream, ensuring that all intermediately buffered contents reach their destination.

fn is_write_vectored(&self) -> bool

🔬 This is a nightly-only experimental API. (can_vector)

Determines if this Writeer has an efficient write_vectored implementation.

fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>

Attempts to write an entire buffer into this writer.

fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>

🔬 This is a nightly-only experimental API. (write_all_vectored)

Attempts to write multiple buffers into this writer.

fn write_fmt(&mut self, fmt: Arguments<'_>) -> Result<(), Error>

Writes a formatted string into this writer, returning any error encountered.

fn by_ref(&mut self) -> &mut Self

Creates a "by reference" adaptor for this instance of Write.