Struct tokio_core::channel::Sender

pub struct Sender<T> { /* fields omitted */ }

Deprecated since 0.1.1

: use futures::sync::mpsc instead

The transmission half of a channel used for sending messages to a receiver.

A Sender can be cloned to have multiple threads or instances sending messages to one receiver.

This type is created by the channel function.

Methods

impl<T> Sender<T>

fn send(&self, t: T) -> Result<()>

Deprecated since 0.1.1

: use futures::sync::mpsc instead

Sends a message to the corresponding receiver of this sender.

The message provided will be enqueued on the channel immediately, and this function will return immediately. Keep in mind that the underlying channel has infinite capacity, and this may not always be desired.

If an I/O error happens while sending the message, or if the receiver has gone away, then an error will be returned. Note that I/O errors here are generally quite abnormal.

Trait Implementations

impl<T> Sink for Sender<T>

type SinkItem = T

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, t: T) -> StartSend<T, Error>

Begin the process of sending a value to the sink.

fn poll_complete(&mut self) -> Poll<(), Error>

Make progress on all pending requests, and determine whether they have completed.

fn with<U, F, Fut>(self, f: F) -> With<Self, U, F, Fut> where F: FnMut(U) -> Fut, Fut: IntoFuture<Item=Self::SinkItem>, Fut::Error: From<Self::SinkError>

Composes a function in front of the sink.

fn buffer(self, amt: usize) -> Buffer<Self>

Adds a fixed-size buffer to the current sink.

fn flush(self) -> Flush<Self>

A future that completes when the sink has finished processing all pending requests.

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.

fn send_all<S>(self, stream: S) -> SendAll<Self, S> where S: Stream<Item=Self::SinkItem>, Self::SinkError: From<S::Error>

A future that completes after the given stream has been fully processed into the sink, including flushing.

impl<T> Clone for Sender<T>

fn clone(&self) -> Sender<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.