[][src]Struct jsonrpc_server_utils::codecs::StreamCodec

pub struct StreamCodec { /* fields omitted */ }

Stream codec for streaming protocols (ipc, tcp)

Methods

impl StreamCodec[src]

pub fn stream_incoming() -> Self[src]

Default codec with streaming input data. Input can be both enveloped and not.

pub fn new(incoming_separator: Separator, outgoing_separator: Separator) -> Self[src]

New custom stream codec

Trait Implementations

impl Default for StreamCodec[src]

impl Debug for StreamCodec[src]

impl Encoder for StreamCodec[src]

type Item = String

The type of items consumed by the Encoder

type Error = Error

The type of encoding errors. Read more

impl Decoder for StreamCodec[src]

type Item = String

The type of decoded frames.

type Error = Error

The type of unrecoverable frame decoding errors. Read more

fn decode_eof(
    &mut self,
    buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>
[src]

A default method available to be called when there are no more bytes available to be read from the underlying I/O. Read more

fn framed<T>(self, io: T) -> Framed<T, Self> where
    Self: Encoder,
    T: AsyncRead + AsyncWrite
[src]

Provides a Stream and Sink interface for reading and writing to this Io object, using Decode and Encode to read and write the raw data. Read more

Auto Trait Implementations

impl Unpin for StreamCodec

impl Sync for StreamCodec

impl Send for StreamCodec

impl UnwindSafe for StreamCodec

impl RefUnwindSafe for StreamCodec

Blanket Implementations

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]