Struct BidirectionalWriter

pub struct BidirectionalWriter<S> { /* private fields */ }

A writer that can write both requests and responses.

Implementations

impl BidirectionalWriter<UnboundedSender<BidirectionalMessage>>

pub fn unbounded<W>( executor: &Executor, writer: W, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

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

Create a new BidirectionalWriter with a custom writer gated behind an unbounded sender.

pub fn stdout_unbounded( executor: &Executor, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

Create a new BidirectionalWriter that prints requests and responses to stdout over an unbounded channel.

pub fn stderr_unbounded( executor: &Executor, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

Create a new BidirectionalWriter that prints requests and responses to stderr over an unbounded channel.

impl BidirectionalWriter<Sender<BidirectionalMessage>>

pub fn new<W>( executor: &Executor, writer: W, buffer: usize, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

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

Create a new BidirectionalWriter with a custom writer gated behind a custom bounded channel.

pub fn last<W>( executor: &Executor, writer: W, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

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

Create a new BidirectionalWriter with a custom writer that only writes the last request and response received.

pub fn stdout( executor: &Executor, buffer: usize, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

Create a new BidirectionalWriter that prints requests and responses to stdout over a bounded channel.

pub fn stdout_last( executor: &Executor, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

Create a new BidirectionalWriter that prints the last request and response to stdout.

pub fn stderr( executor: &Executor, buffer: usize, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

Create a new BidirectionalWriter that prints requests and responses to stderr over a bounded channel.

pub fn stderr_last( executor: &Executor, request_mode: Option<WriterMode>, response_mode: Option<WriterMode>, ) -> Self

Create a new BidirectionalWriter that prints the last request and responses to stderr.

Trait Implementations

impl<S: Clone> Clone for BidirectionalWriter<S>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S> Debug for BidirectionalWriter<S>

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

Formats the value using the given formatter.

impl RequestWriter for BidirectionalWriter<Sender<BidirectionalMessage>>

async fn write_request(&self, req: Request)

Write the http request.

impl RequestWriter for BidirectionalWriter<UnboundedSender<BidirectionalMessage>>

async fn write_request(&self, req: Request)

Write the http request.

impl ResponseWriter for BidirectionalWriter<Sender<BidirectionalMessage>>

async fn write_response(&self, res: Response)

Write the http response.

impl ResponseWriter for BidirectionalWriter<UnboundedSender<BidirectionalMessage>>

async fn write_response(&self, res: Response)

Write the http response.