Struct tokio_udp_framed::UdpFramedSend [−][src]
A Sink of frames encoded for udp.
Implementations
impl<T, C> UdpFramedSend<T, C> where
T: Borrow<UdpSocket>, [src]
T: Borrow<UdpSocket>,
pub fn new(socket: T, codec: C) -> UdpFramedSend<T, C>[src]
Create a new UdpFramed backed by the given socket and codec.
See struct level documentation for more details.
pub fn get_ref(&self) -> &UdpSocket[src]
Returns a reference to the underlying I/O stream wrapped by Framed.
Note
Care should be taken to not tamper with the underlying stream of data coming in as it may corrupt the stream of frames otherwise being worked with.
pub fn encoder(&self) -> &C[src]
Returns a reference to the underlying codec wrapped by
Framed.
Note that care should be taken to not tamper with the underlying codec as it may corrupt the stream of frames otherwise being worked with.
pub fn encoder_mut(&mut self) -> &mut C[src]
Returns a mutable reference to the underlying codec wrapped by
UdpFramed.
Note that care should be taken to not tamper with the underlying codec as it may corrupt the stream of frames otherwise being worked with.
pub fn into_inner(self) -> T[src]
Consumes the Framed, returning its underlying I/O stream.
Trait Implementations
impl<T, C> Debug for UdpFramedSend<T, C> where
T: Borrow<UdpSocket>,
C: Debug, [src]
T: Borrow<UdpSocket>,
C: Debug,
impl<T, I, U> Sink<(I, SocketAddr)> for UdpFramedSend<T, U> where
T: Borrow<UdpSocket>,
U: Encoder<I>,
U::Error: From<Error>, [src]
T: Borrow<UdpSocket>,
U: Encoder<I>,
U::Error: From<Error>,
type Error = U::Error
The type of value produced by the sink when an error occurs.
fn poll_ready(
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>[src]
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>
fn start_send(
self: Pin<&mut Self>,
item: (I, SocketAddr)
) -> Result<(), Self::Error>[src]
self: Pin<&mut Self>,
item: (I, SocketAddr)
) -> Result<(), Self::Error>
fn poll_flush(
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>[src]
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>
fn poll_close(
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>[src]
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>
impl<'__pin, T, C> Unpin for UdpFramedSend<T, C> where
__Origin<'__pin, T, C>: Unpin, [src]
__Origin<'__pin, T, C>: Unpin,
Auto Trait Implementations
impl<T, C> RefUnwindSafe for UdpFramedSend<T, C> where
C: RefUnwindSafe,
T: RefUnwindSafe, [src]
C: RefUnwindSafe,
T: RefUnwindSafe,
impl<T, C> Send for UdpFramedSend<T, C> where
C: Send,
T: Send, [src]
C: Send,
T: Send,
impl<T, C> Sync for UdpFramedSend<T, C> where
C: Sync,
T: Sync, [src]
C: Sync,
T: Sync,
impl<T, C> UnwindSafe for UdpFramedSend<T, C> where
C: UnwindSafe,
T: UnwindSafe, [src]
C: UnwindSafe,
T: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, Item> SinkExt<Item> for T where
T: Sink<Item> + ?Sized, [src]
T: Sink<Item> + ?Sized,
pub fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where
E: From<Self::Error>,
Fut: Future<Output = Result<Item, E>>,
F: FnMut(U) -> Fut, [src]
E: From<Self::Error>,
Fut: Future<Output = Result<Item, E>>,
F: FnMut(U) -> Fut,
pub fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where
St: Stream<Item = Result<Item, Self::Error>>,
F: FnMut(U) -> St, [src]
St: Stream<Item = Result<Item, Self::Error>>,
F: FnMut(U) -> St,
pub fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where
F: FnOnce(Self::Error) -> E, [src]
F: FnOnce(Self::Error) -> E,
pub fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where
Self::Error: Into<E>, [src]
Self::Error: Into<E>,
pub fn buffer(self, capacity: usize) -> Buffer<Self, Item>[src]
pub fn close(&mut self) -> Close<'_, Self, Item> where
Self: Unpin, [src]
Self: Unpin,
pub fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where
Item: Clone,
Si: Sink<Item, Error = Self::Error>, [src]
Item: Clone,
Si: Sink<Item, Error = Self::Error>,
pub fn flush(&mut self) -> Flush<'_, Self, Item> where
Self: Unpin, [src]
Self: Unpin,
pub fn send(&mut self, item: Item) -> Send<'_, Self, Item> where
Self: Unpin, [src]
Self: Unpin,
pub fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> where
Self: Unpin, [src]
Self: Unpin,
pub fn send_all<St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> where
Self: Unpin,
St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized, [src]
Self: Unpin,
St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized,
pub fn left_sink<Si2>(self) -> Either<Self, Si2> where
Si2: Sink<Item, Error = Self::Error>, [src]
Si2: Sink<Item, Error = Self::Error>,
pub fn right_sink<Si1>(self) -> Either<Si1, Self> where
Si1: Sink<Item, Error = Self::Error>, [src]
Si1: Sink<Item, Error = Self::Error>,
pub fn poll_ready_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>> where
Self: Unpin, [src]
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
pub fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error> where
Self: Unpin, [src]
Self: Unpin,
pub fn poll_flush_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>> where
Self: Unpin, [src]
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
pub fn poll_close_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>> where
Self: Unpin, [src]
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>> where
Self: Unpin,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,