Struct ResponseWriterLayer 

pub struct ResponseWriterLayer<W> { /* private fields */ }

Available on crate features http and std only.

Layer that applies ResponseWriterService which prints the http response in std format.

Response bodies are observed while they stream to the caller. The writer receives an owned body stream and processes frames concurrently.

Implementations

impl<W> ResponseWriterLayer<W>

pub const fn new(writer: W) -> ResponseWriterLayer<W>

Create a new ResponseWriterLayer with a custom ResponseWriter.

Use Self::new_with_executor when streaming writer tasks must participate in graceful shutdown.

pub const fn new_with_executor( writer: W, executor: Executor, ) -> ResponseWriterLayer<W>

Create a new ResponseWriterLayer with a custom ResponseWriter and executor for streaming writer tasks.

impl ResponseWriterLayer<UnboundedSender<Response>>

pub fn writer_unbounded<W>( executor: &Executor, writer: W, mode: Option<WriterMode>, ) -> ResponseWriterLayer<UnboundedSender<Response>>

where W: AsyncWrite + Unpin + Send + Sync + 'static,

Create a new ResponseWriterLayer that prints responses to an [AsyncWrite]r over an unbounded channel

pub fn stdout_unbounded( executor: &Executor, mode: Option<WriterMode>, ) -> ResponseWriterLayer<UnboundedSender<Response>>

Create a new ResponseWriterLayer that prints responses to stdout over an unbounded channel.

pub fn stderr_unbounded( executor: &Executor, mode: Option<WriterMode>, ) -> ResponseWriterLayer<UnboundedSender<Response>>

Create a new ResponseWriterLayer that prints responses to stderr over an unbounded channel.

impl ResponseWriterLayer<PerMessageFileWriter>

pub async fn file_per_response( executor: &Executor, directory: impl Into<PathBuf>, prefix: impl AsRef<str>, mode: Option<WriterMode>, ) -> Result<ResponseWriterLayer<PerMessageFileWriter>, Error>

Create a layer that streams every response into a unique file below directory using the portable filename prefix.

impl ResponseWriterLayer<Sender<Response>>

pub fn writer<W>( executor: &Executor, writer: W, buffer_size: usize, mode: Option<WriterMode>, ) -> ResponseWriterLayer<Sender<Response>>

where W: AsyncWrite + Unpin + Send + Sync + 'static,

Create a new ResponseWriterLayer that prints responses to an [AsyncWrite]r over a bounded channel with a fixed buffer size.

pub fn stdout( executor: &Executor, buffer_size: usize, mode: Option<WriterMode>, ) -> ResponseWriterLayer<Sender<Response>>

Create a new ResponseWriterLayer that prints responses to stdout over a bounded channel with a fixed buffer size.

pub fn stderr( executor: &Executor, buffer_size: usize, mode: Option<WriterMode>, ) -> ResponseWriterLayer<Sender<Response>>

Create a new ResponseWriterLayer that prints responses to stderr over a bounded channel with a fixed buffer size.

Trait Implementations

impl<W> Clone for ResponseWriterLayer<W>

where W: Clone,

fn clone(&self) -> ResponseWriterLayer<W>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<W> Debug for ResponseWriterLayer<W>

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

Formats the value using the given formatter.

impl<S, W> Layer<S> for ResponseWriterLayer<W>

where W: Clone,

type Service = ResponseWriterService<S, W>

The service produced by the layer.

fn layer(&self, inner: S) -> <ResponseWriterLayer<W> as Layer<S>>::Service

Wrap the given service with the middleware, returning a new service.

fn into_layer(self, inner: S) -> <ResponseWriterLayer<W> as Layer<S>>::Service

Same as layer but consuming self after the service was created.