1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use crossbeam_channel::Receiver;

use crate::errors::Result;
use crate::response::Response;
use crate::Event;

/// `Sender` is responsible for handling events after Send() is called.  Implementations
/// of `send()` must be safe for concurrent calls.
pub trait Sender {
    /// `send` queues up an event to be sent
    fn send(&mut self, ev: Event);

    /// `start` initializes any background processes necessary to send events
    fn start(&mut self);

    /// `stop` flushes any pending queues and blocks until everything in flight has been
    /// sent
    fn stop(&mut self) -> Result<()>;

    /// `responses` returns a channel that will contain a single Response for each Event
    /// added. Note that they may not be in the same order as they came in
    fn responses(&self) -> Receiver<Response>;
}