Struct JsonLinesSink

pub struct JsonLinesSink<W, T> { /* private fields */ }

Available on crate feature async only.

An asynchronous sink that serializes input values of type T as JSON and writes them to the underlying AsyncWrite value W.

Sinks of this type are returned by AsyncJsonLinesWriter::into_sink() and AsyncWriteJsonLines::into_json_lines_sink().

Trait Implementations

impl<W: Clone, T: Clone> Clone for JsonLinesSink<W, T>

fn clone(&self) -> JsonLinesSink<W, T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<W: Debug, T: Debug> Debug for JsonLinesSink<W, T>

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

Formats the value using the given formatter.

impl<W: PartialEq, T: PartialEq> PartialEq for JsonLinesSink<W, T>

fn eq(&self, other: &JsonLinesSink<W, T>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<W: AsyncWrite, T> Sink<T> for JsonLinesSink<W, T>

where T: Serialize,

type Error = Error

The type of value produced by the sink when an error occurs.

fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to prepare the Sink to receive a value.

fn start_send(self: Pin<&mut Self>, item: T) -> Result<()>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Flush any remaining output from this sink.

fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Flush any remaining output and close this sink, if necessary.

impl<W: Eq, T: Eq> Eq for JsonLinesSink<W, T>

impl<W, T> StructuralPartialEq for JsonLinesSink<W, T>

impl<'__pin, W, T> Unpin for JsonLinesSink<W, T>

where __Origin<'__pin, W, T>: Unpin,