mediator 0.2.2

An implementation of the Mediator pattern in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use tokio_stream::Stream;

/// Represents a request that produces a stream of responses to the mediator.
pub trait StreamRequest {
    /// Type of the stream produced by this request.
    type Stream: Stream<Item = Self::Item>;

    /// Type of the item produced by the stream.
    type Item;
}

/// Handles a request and returns a stream of responses.
pub trait StreamRequestHandler {
    /// Type of the request handled by this handler.
    type Request: StreamRequest<Stream = Self::Stream, Item = Self::Item>;

    /// Type of the stream produced by this request.
    type Stream: Stream<Item = Self::Item>;

    /// Type of the item produced by the stream.
    type Item;

    /// Handles a request and returns a stream of responses.
    fn handle_stream(&mut self, req: Self::Request) -> Self::Stream;
}