Trait barter_integration::protocol::StreamParser

pub trait StreamParser {
    type Message;
    type Error;

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

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 Message

type Error

Required Methods

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

Implementors

impl StreamParser for WebSocketParser

type Message = Message

type Error = Error