Struct tokio_zmq::async_types::sink::MultipartSink [−][src]
pub struct MultipartSink { /* fields omitted */ }
The MultipartSink
Sink handles sending streams of data to ZeroMQ Sockets.
You shouldn't ever need to manually create one. Here's how to get one from a 'raw' Socket
'
type.
Example
extern crate zmq; extern crate futures; extern crate tokio; extern crate tokio_zmq; use std::sync::Arc; use futures::{Future, Sink}; use tokio_zmq::{prelude::*, Error, Multipart, Pub, Socket}; fn get_sink(socket: Socket) -> impl Sink<SinkItem = Multipart, SinkError = Error> { socket.sink() } fn main() { let context = Arc::new(zmq::Context::new()); let socket = Pub::builder(context) .bind("tcp://*:5568") .build() .unwrap() .socket(); let sink = get_sink(socket); let msg = zmq::Message::from_slice(b"Some message"); // tokio::run(sink.send(msg.into())).unwrap(); }
Methods
impl MultipartSink
[src]
impl MultipartSink
pub fn new(sock: Socket, file: EventedFile) -> Self
[src]
pub fn new(sock: Socket, file: EventedFile) -> Self
Trait Implementations
impl Sink for MultipartSink
[src]
impl Sink for MultipartSink
type SinkItem = Multipart
The type of value that the sink accepts.
type SinkError = Error
The type of value produced by the sink when an error occurs.
fn start_send(
&mut self,
multipart: Self::SinkItem
) -> Result<AsyncSink<Self::SinkItem>, Self::SinkError>
[src]
fn start_send(
&mut self,
multipart: Self::SinkItem
) -> Result<AsyncSink<Self::SinkItem>, Self::SinkError>
Begin the process of sending a value to the sink. Read more
fn poll_complete(&mut self) -> Result<Async<()>, Self::SinkError>
[src]
fn poll_complete(&mut self) -> Result<Async<()>, Self::SinkError>
Flush all output from this sink, if necessary. Read more
fn close(&mut self) -> Result<Async<()>, Self::SinkError>
[src]
fn close(&mut self) -> Result<Async<()>, Self::SinkError>
A method to indicate that no more values will ever be pushed into this sink. Read more
fn wait(self) -> Wait<Self>
[src]
fn wait(self) -> Wait<Self>
Creates a new object which will produce a synchronous sink. Read more
fn with<U, F, Fut>(self, f: F) -> With<Self, U, F, Fut> where
F: FnMut(U) -> Fut,
Fut: IntoFuture<Item = Self::SinkItem>,
<Fut as IntoFuture>::Error: From<Self::SinkError>,
[src]
fn with<U, F, Fut>(self, f: F) -> With<Self, U, F, Fut> where
F: FnMut(U) -> Fut,
Fut: IntoFuture<Item = Self::SinkItem>,
<Fut as IntoFuture>::Error: From<Self::SinkError>,
Composes a function in front of the sink. Read more
fn with_flat_map<U, F, St>(self, f: F) -> WithFlatMap<Self, U, F, St> where
F: FnMut(U) -> St,
St: Stream<Item = Self::SinkItem, Error = Self::SinkError>,
[src]
fn with_flat_map<U, F, St>(self, f: F) -> WithFlatMap<Self, U, F, St> where
F: FnMut(U) -> St,
St: Stream<Item = Self::SinkItem, Error = Self::SinkError>,
Composes a function in front of the sink. Read more
fn sink_map_err<F, E>(self, f: F) -> SinkMapErr<Self, F> where
F: FnOnce(Self::SinkError) -> E,
[src]
fn sink_map_err<F, E>(self, f: F) -> SinkMapErr<Self, F> where
F: FnOnce(Self::SinkError) -> E,
Transforms the error returned by the sink.
fn sink_from_err<E>(self) -> SinkFromErr<Self, E> where
E: From<Self::SinkError>,
[src]
fn sink_from_err<E>(self) -> SinkFromErr<Self, E> where
E: From<Self::SinkError>,
Map this sink's error to any error implementing From
for this sink's Error
, returning a new sink. Read more
fn buffer(self, amt: usize) -> Buffer<Self>
[src]
fn buffer(self, amt: usize) -> Buffer<Self>
Adds a fixed-size buffer to the current sink. Read more
fn fanout<S>(self, other: S) -> Fanout<Self, S> where
S: Sink<SinkItem = Self::SinkItem, SinkError = Self::SinkError>,
Self::SinkItem: Clone,
[src]
fn fanout<S>(self, other: S) -> Fanout<Self, S> where
S: Sink<SinkItem = Self::SinkItem, SinkError = Self::SinkError>,
Self::SinkItem: Clone,
Fanout items to multiple sinks. Read more
fn flush(self) -> Flush<Self>
[src]
fn flush(self) -> Flush<Self>
A future that completes when the sink has finished processing all pending requests. Read more
fn send(self, item: Self::SinkItem) -> Send<Self>
[src]
fn send(self, item: Self::SinkItem) -> Send<Self>
A future that completes after the given item has been fully processed into the sink, including flushing. Read more
fn send_all<S>(self, stream: S) -> SendAll<Self, S> where
S: Stream<Item = Self::SinkItem>,
Self::SinkError: From<<S as Stream>::Error>,
[src]
fn send_all<S>(self, stream: S) -> SendAll<Self, S> where
S: Stream<Item = Self::SinkItem>,
Self::SinkError: From<<S as Stream>::Error>,
A future that completes after the given stream has been fully processed into the sink, including flushing. Read more
Auto Trait Implementations
impl Send for MultipartSink
impl Send for MultipartSink
impl !Sync for MultipartSink
impl !Sync for MultipartSink