Trait async_zmq_types::InnerSocket

pub trait InnerSocket<T>: Sizedwhere
    T: IntoInnerSocket + From<Self>,{
    type Request: Future<Item = T>;
    type Response: Future<Item = (Multipart, T)>;
    type Stream: Stream<Item = Multipart>;
    type Sink: Sink<SinkItem = Multipart>;
    type SinkStream: Stream<Item = Multipart> + Sink<SinkItem = Multipart>;

    fn send(self, multipart: Multipart) -> Self::Request;
    fn recv(self) -> Self::Response;
    fn stream(self) -> Self::Stream;
    fn sink(self, buffer_size: usize) -> Self::Sink;
    fn sink_stream(self, buffer_size: usize) -> Self::SinkStream;
}

Define all actions possible on a socket

This should be generic enough to implement over any executor. On Tokio, this might consist of a Socket with an EventedFd, on Futures, it might just be a Socket.

Required Associated Types

type Request: Future<Item = T>

The future that sends a multipart to a ZMQ socket

type Response: Future<Item = (Multipart, T)>

The future that receives a multipart from a ZMQ socket

type Stream: Stream<Item = Multipart>

A Stream of multiparts received from a ZMQ socket

type Sink: Sink<SinkItem = Multipart>

A Sink that sends multiparts to a ZMQ socket

type SinkStream: Stream<Item = Multipart> + Sink<SinkItem = Multipart>

A Sink and Stream that sends and receives multiparts from a ZMQ socket

Required Methods

fn send(self, multipart: Multipart) -> Self::Request

fn recv(self) -> Self::Response

fn stream(self) -> Self::Stream

fn sink(self, buffer_size: usize) -> Self::Sink

fn sink_stream(self, buffer_size: usize) -> Self::SinkStream

Implementors