Struct RequestWriterService 

pub struct RequestWriterService<S, W> { /* private fields */ }

Available on crate features http and std only.

Middleware to print Http request in std format.

Request bodies are observed while they stream to the inner service. The writer receives an owned body stream and processes frames concurrently.

See the module docs for more details.

Implementations

impl<S, W> RequestWriterService<S, W>

pub fn new(inner: S, writer: W) -> RequestWriterService<S, W>

Create a new RequestWriterService with a custom RequestWriter.

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

pub fn new_with_executor( inner: S, writer: W, executor: Executor, ) -> RequestWriterService<S, W>

Create a new RequestWriterService with a custom RequestWriter and executor for streaming writer tasks.

impl<S> RequestWriterService<S, UnboundedSender<Request>>

pub fn writer_unbounded<W>( inner: S, executor: &Executor, writer: W, mode: Option<WriterMode>, ) -> RequestWriterService<S, UnboundedSender<Request>>

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

Create a new RequestWriterService that prints requests to an [AsyncWrite]r over an unbounded channel

pub fn stdout_unbounded( inner: S, executor: &Executor, mode: Option<WriterMode>, ) -> RequestWriterService<S, UnboundedSender<Request>>

Create a new RequestWriterService that prints requests to stdout over an unbounded channel.

pub fn stderr_unbounded( inner: S, executor: &Executor, mode: Option<WriterMode>, ) -> RequestWriterService<S, UnboundedSender<Request>>

Create a new RequestWriterService that prints requests to stderr over an unbounded channel.

impl<S> RequestWriterService<S, PerMessageFileWriter>

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

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

impl<S> RequestWriterService<S, Sender<Request>>

pub fn writer<W>( inner: S, executor: &Executor, writer: W, buffer_size: usize, mode: Option<WriterMode>, ) -> RequestWriterService<S, Sender<Request>>

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

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

pub fn stdout( inner: S, executor: &Executor, buffer_size: usize, mode: Option<WriterMode>, ) -> RequestWriterService<S, Sender<Request>>

Create a new RequestWriterService that prints requests to stdout over a bounded channel with a fixed buffer size.

pub fn stderr( inner: S, executor: &Executor, buffer_size: usize, mode: Option<WriterMode>, ) -> RequestWriterService<S, Sender<Request>>

Create a new RequestWriterService that prints requests to stderr over a bounded channel with a fixed buffer size.

Trait Implementations

impl<S, W> Clone for RequestWriterService<S, W>

where S: Clone, W: Clone,

fn clone(&self) -> RequestWriterService<S, W>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, W> Debug for RequestWriterService<S, W>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, W, ReqBody> Service<Request<ReqBody>> for RequestWriterService<S, W>

where S: Service<Request>, <S as Service<Request>>::Error: Into<Box<dyn Error + Sync + Send>>, ReqBody: Body<Data = Bytes> + Send + Sync + 'static, <ReqBody as Body>::Error: Into<Box<dyn Error + Sync + Send>>, W: RequestWriter,

type Error = Box<dyn Error + Sync + Send>

The type of error returned by the service.

type Output = <S as Service<Request>>::Output

The type of the output returned by the service.

async fn serve( &self, req: Request<ReqBody>, ) -> Result<<RequestWriterService<S, W> as Service<Request<ReqBody>>>::Output, <RequestWriterService<S, W> as Service<Request<ReqBody>>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.