Trait StreamParser 

pub trait StreamParser<Output> {
    type Stream: Stream;
    type Message;
    type Error;

    // Required method
    fn parse(
        input: Result<Self::Message, Self::Error>,
    ) -> Option<Result<Output, SocketError>>;
}

StreamParsers are capable of parsing the input messages from a given stream protocol (eg/ WebSocket, Financial Information eXchange (FIX), etc.) and deserialising into an Output.

Required Associated Types

type Stream: Stream

type Message

type Error

Required Methods

fn parse( input: Result<Self::Message, Self::Error>, ) -> Option<Result<Output, SocketError>>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<Output> StreamParser<Output> for WebSocketProtobufParser

where Output: Message + Default,

type Stream = WebSocketStream<MaybeTlsStream<TcpStream>>

type Message = Message

type Error = Error

impl<Output> StreamParser<Output> for WebSocketSerdeParser

where Output: for<'de> Deserialize<'de>,

type Stream = WebSocketStream<MaybeTlsStream<TcpStream>>

type Message = Message

type Error = Error