pub struct ListenerSynchronousProxy { /* private fields */ }
Implementations§
source§impl ListenerSynchronousProxy
impl ListenerSynchronousProxy
pub fn new(channel: Channel) -> Self
pub fn into_channel(self) -> Channel
sourcepub fn wait_for_event(
&self,
deadline: MonotonicInstant,
) -> Result<ListenerEvent, Error>
pub fn wait_for_event( &self, deadline: MonotonicInstant, ) -> Result<ListenerEvent, Error>
Waits until an event arrives and returns it. It is safe for other threads to make concurrent requests while waiting for an event.
sourcepub fn listen(
&self,
backlog: u32,
___deadline: MonotonicInstant,
) -> Result<ListenerListenResult, Error>
pub fn listen( &self, backlog: u32, ___deadline: MonotonicInstant, ) -> Result<ListenerListenResult, Error>
Registers a listener for a local port. There can only be one listener for
a single port at a time. The channel will have SIGNAL_STREAM_INCOMING
asserted
by the server when there is a connection ready to accept.
sourcepub fn accept(
&self,
con: ConnectionTransport,
___deadline: MonotonicInstant,
) -> Result<ListenerAcceptResult, Error>
pub fn accept( &self, con: ConnectionTransport, ___deadline: MonotonicInstant, ) -> Result<ListenerAcceptResult, Error>
Accept a pending connection from the queue after Listen
was invoked and
SIGNAL_STREAM_INCOMING
was signaled.
Trait Implementations§
source§impl Debug for ListenerSynchronousProxy
impl Debug for ListenerSynchronousProxy
source§impl SynchronousProxy for ListenerSynchronousProxy
impl SynchronousProxy for ListenerSynchronousProxy
§type Proxy = ListenerProxy
type Proxy = ListenerProxy
The async proxy for the same protocol.
§type Protocol = ListenerMarker
type Protocol = ListenerMarker
The protocol which this
Proxy
controls.source§fn from_channel(inner: Channel) -> Self
fn from_channel(inner: Channel) -> Self
Create a proxy over the given channel.
source§fn into_channel(self) -> Channel
fn into_channel(self) -> Channel
Convert the proxy back into a channel.
source§fn as_channel(&self) -> &Channel
fn as_channel(&self) -> &Channel
Get a reference to the proxy’s underlying channel. Read more
Auto Trait Implementations§
impl Freeze for ListenerSynchronousProxy
impl RefUnwindSafe for ListenerSynchronousProxy
impl Send for ListenerSynchronousProxy
impl Sync for ListenerSynchronousProxy
impl Unpin for ListenerSynchronousProxy
impl UnwindSafe for ListenerSynchronousProxy
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