pub struct Consumer { /* private fields */ }Expand description
Subscriber for one physical track.
Grouped authentication failure is sticky and ends the track. A bad datagram
is dropped with Event::Authentication and the track continues.
Implementations§
Source§impl Consumer
impl Consumer
Sourcepub fn poll_recv_group(
&mut self,
waiter: &Waiter,
) -> Poll<Result<Option<Consumer>>>
pub fn poll_recv_group( &mut self, waiter: &Waiter, ) -> Poll<Result<Option<Consumer>>>
Poll for the next protected group in arrival order.
§Errors
Error::Authentication once a grouped frame has failed to open, or a net error.
Sourcepub async fn recv_group(&mut self) -> Result<Option<Consumer>>
pub async fn recv_group(&mut self) -> Result<Option<Consumer>>
Sourcepub fn poll_recv_datagram(
&mut self,
waiter: &Waiter,
) -> Poll<Result<Option<Event>>>
pub fn poll_recv_datagram( &mut self, waiter: &Waiter, ) -> Poll<Result<Option<Event>>>
Poll for the next datagram event.
A bad tag and a duplicate are events, not track-ending errors.
§Errors
Error::Authentication only if a grouped frame already failed,
Error::Oversize or Error::Exhausted from opening, or a net error.
Sourcepub async fn recv_datagram(&mut self) -> Result<Option<Event>>
pub async fn recv_datagram(&mut self) -> Result<Option<Event>>
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for Consumer
impl !UnwindSafe for Consumer
impl Freeze for Consumer
impl Send for Consumer
impl Sync for Consumer
impl Unpin for Consumer
impl UnsafeUnpin for Consumer
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