pub struct EntryIteratorProxy { /* private fields */ }
Implementations§
source§impl EntryIteratorProxy
impl EntryIteratorProxy
sourcepub fn take_event_stream(&self) -> EntryIteratorEventStream
pub fn take_event_stream(&self) -> EntryIteratorEventStream
Get a Stream of events from the remote end of the EntryIterator protocol
Panics
Panics if the event stream was already taken.
sourcepub fn get_next(&self) -> QueryResponseFut<Vec<EntryIteratorItem>>
pub fn get_next(&self) -> QueryResponseFut<Vec<EntryIteratorItem>>
Take items from the iterator. If no items are available, block until one is; otherwise, return immediately with items queued since the last invocation.
This does not guarantee that, when blocking, only one item will be returned; implementations may debounce or batch events.
Clients should only have one call of this method at a time; a second call to this method while a call is already pending will cause the server end of the protocol to be closed.
- response
events
a list of events that occurred since the last invocation of this method.
Trait Implementations§
source§impl Clone for EntryIteratorProxy
impl Clone for EntryIteratorProxy
source§fn clone(&self) -> EntryIteratorProxy
fn clone(&self) -> EntryIteratorProxy
Returns a copy 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 EntryIteratorProxy
impl Debug for EntryIteratorProxy
source§impl EntryIteratorProxyInterface for EntryIteratorProxy
impl EntryIteratorProxyInterface for EntryIteratorProxy
type GetNextResponseFut = QueryResponseFut<Vec<EntryIteratorItem, Global>>
fn get_next(&self) -> Self::GetNextResponseFut
source§impl Proxy for EntryIteratorProxy
impl Proxy for EntryIteratorProxy
§type Protocol = EntryIteratorMarker
type Protocol = EntryIteratorMarker
The protocol which this
Proxy
controls.source§fn from_channel(inner: AsyncChannel) -> Self
fn from_channel(inner: AsyncChannel) -> Self
Create a proxy over the given channel.
source§fn into_channel(self) -> Result<AsyncChannel, Self>
fn into_channel(self) -> Result<AsyncChannel, Self>
Attempt to convert the proxy back into a channel. Read more
source§fn as_channel(&self) -> &AsyncChannel
fn as_channel(&self) -> &AsyncChannel
Get a reference to the proxy’s underlying channel. Read more