pub struct EventbusWriteFuture { /* private fields */ }
Expand description
Responsible for writing messages to the server through vert.x protocol.
Should be spawned into background.
Can be created by calling Eventbus::connect
.
Trait Implementations§
Source§impl IntoFuture for EventbusWriteFuture
impl IntoFuture for EventbusWriteFuture
Source§type Future = Forward<UnboundedReceiverWithError<Request>, FramedWrite<WriteHalf<TcpStream>, RequestCodec>>
type Future = Forward<UnboundedReceiverWithError<Request>, FramedWrite<WriteHalf<TcpStream>, RequestCodec>>
The future that this type can be converted into.
Source§type Item = (UnboundedReceiverWithError<Request>, FramedWrite<WriteHalf<TcpStream>, RequestCodec>)
type Item = (UnboundedReceiverWithError<Request>, FramedWrite<WriteHalf<TcpStream>, RequestCodec>)
The item that the future may resolve with.
Source§fn into_future(self) -> Self::Future
fn into_future(self) -> Self::Future
Consumes this object and produces a future.
Auto Trait Implementations§
impl !Freeze for EventbusWriteFuture
impl !RefUnwindSafe for EventbusWriteFuture
impl Send for EventbusWriteFuture
impl Sync for EventbusWriteFuture
impl Unpin for EventbusWriteFuture
impl !UnwindSafe for EventbusWriteFuture
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more