Trait futures_zmq::prelude::SinkStreamSocket

pub trait SinkStreamSocket: IntoInnerSocket {
    fn sink_stream(
        self, 
        buffer_size: usize
    ) -> <Self::Socket as InnerSocket<Self>>::SinkStream;
}

This trait is provided for sockets that implement both Sync and Stream

Required methods

fn sink_stream(
    self,
    buffer_size: usize
) -> <Self::Socket as InnerSocket<Self>>::SinkStream

Retrieve a structure that implements both Sync and Stream.

It takes a buffer_size argument, which will determine how many Multiparts can be submitted into the send queue before the sink applies backpressure.

Example, using a Rep wrapper type

extern crate futures;
extern crate tokio_zmq;
extern crate zmq;

use std::sync::Arc;

use futures::{Future, Stream};
use tokio_zmq::{prelude::*, Rep};

fn main() {
    let ctx = Arc::new(zmq::Context::new());
    let fut = Rep::builder(ctx)
        .bind("tcp://*:5571")
        .build()
        .and_then(|rep| {
            let (sink, stream) = rep.sink_stream(25).split();

            stream.forward(sink)
        });

    // tokio::run(fut.map(|_| ()).or_else(|e| {
    //     println!("Error: {}", e);
    //     Ok(())
    // }));
}

Loading content...

Implementors

impl<T> SinkStreamSocket for T where
    T: StreamSocket + SinkSocket, 

fn sink_stream(
    self,
    buffer_size: usize
) -> <<T as IntoInnerSocket>::Socket as InnerSocket<T>>::SinkStream

Loading content...