pub struct ServiceConsumerSynchronousProxy { /* private fields */ }
Implementations§
source§impl ServiceConsumerSynchronousProxy
impl ServiceConsumerSynchronousProxy
pub fn new(channel: Channel) -> Self
pub fn into_channel(self) -> Channel
sourcepub fn wait_for_event(
&self,
deadline: Time
) -> Result<ServiceConsumerEvent, Error>
pub fn wait_for_event( &self, deadline: Time ) -> Result<ServiceConsumerEvent, 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 list_peers(&self, ___deadline: Time) -> Result<Vec<Peer>, Error>
pub fn list_peers(&self, ___deadline: Time) -> Result<Vec<Peer>, Error>
Returns a list of all peers that are connected to this Overnet. If this list has not been updated since the last call to this method, it waits until new data is available. Concurrent calls to ListPeers will result in channel closure.