azeventhubs 0.20.0

An unofficial AMQP 1.0 rust client for Azure Event Hubs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::time::Duration as StdDuration;

use futures_util::Stream;

pub trait TransportConsumer {
    type ReceivedEvent;
    type ReceiveError: std::error::Error;
    type Stream<'s>: Stream<Item = Result<Self::ReceivedEvent, Self::ReceiveError>>
    where
        Self: 's;

    fn last_received_event(&self) -> Option<&Self::ReceivedEvent>;

    fn receive(
        &mut self,
        maximum_event_count: Option<u32>,
        maximum_wait_time: Option<StdDuration>,
    ) -> Self::Stream<'_>;
}