pub struct StreamSourceProxy { /* private fields */ }Implementations§
Source§impl StreamSourceProxy
impl StreamSourceProxy
Sourcepub fn take_event_stream(&self) -> StreamSourceEventStream
pub fn take_event_stream(&self) -> StreamSourceEventStream
Get a Stream of events from the remote end of the protocol.
§Panics
Panics if the event stream was already taken.
Sourcepub fn release_packet(&self, packet: &StreamPacket) -> Result<(), Error>
pub fn release_packet(&self, packet: &StreamPacket) -> Result<(), Error>
Releases payload memory associated with a packet previously delivered
via OnPacketProduced.
pub fn discard_all_packets( &self, ) -> QueryResponseFut<(), FDomainResourceDialect>
pub fn discard_all_packets_no_reply(&self) -> Result<(), Error>
Trait Implementations§
Source§impl Clone for StreamSourceProxy
impl Clone for StreamSourceProxy
Source§fn clone(&self) -> StreamSourceProxy
fn clone(&self) -> StreamSourceProxy
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for StreamSourceProxy
impl Debug for StreamSourceProxy
Source§impl Proxy for StreamSourceProxy
impl Proxy for StreamSourceProxy
Source§type Protocol = StreamSourceMarker
type Protocol = StreamSourceMarker
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) -> Result<Channel, Self>
fn into_channel(self) -> Result<Channel, Self>
Attempt to convert the proxy back into a channel. Read more
Source§fn as_channel(&self) -> &Channel
fn as_channel(&self) -> &Channel
Get a reference to the proxy’s underlying channel. Read more
Source§fn domain(&self) -> Arc<Client>
fn domain(&self) -> Arc<Client>
Get the client supporting this proxy. We call this a “domain” here because: Read more
Source§fn on_closed(&self) -> OnFDomainSignals
fn on_closed(&self) -> OnFDomainSignals
Returns a future that completes when the server receives the
PEER_CLOSED signal.Source§impl StreamSourceProxyInterface for StreamSourceProxy
impl StreamSourceProxyInterface for StreamSourceProxy
type DiscardAllPacketsResponseFut = QueryResponseFut<(), FDomainResourceDialect>
fn release_packet(&self, packet: &StreamPacket) -> Result<(), Error>
fn discard_all_packets(&self) -> Self::DiscardAllPacketsResponseFut
fn discard_all_packets_no_reply(&self) -> Result<(), Error>
Auto Trait Implementations§
impl Freeze for StreamSourceProxy
impl !RefUnwindSafe for StreamSourceProxy
impl Send for StreamSourceProxy
impl Sync for StreamSourceProxy
impl Unpin for StreamSourceProxy
impl UnsafeUnpin for StreamSourceProxy
impl !UnwindSafe for StreamSourceProxy
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T, D> Encode<Ambiguous1, D> for Twhere
D: ResourceDialect,
impl<T, D> Encode<Ambiguous1, D> for Twhere
D: ResourceDialect,
Source§impl<T, D> Encode<Ambiguous2, D> for Twhere
D: ResourceDialect,
impl<T, D> Encode<Ambiguous2, D> for Twhere
D: ResourceDialect,
§impl<T> InstanceFromServiceTransport<T> for T
impl<T> InstanceFromServiceTransport<T> for T
§fn from_service_transport(handle: T) -> T
fn from_service_transport(handle: T) -> T
Converts the given service transport handle of type
T to [Self]