1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use serde::{Deserialize, Serialize};

/// The Bridge Input.
#[derive(Debug, Serialize, Deserialize)]
pub(crate) enum ReactorInput<I> {
    /// An input message.
    Input(I),
}

/// The Bridge Output.
#[derive(Debug, Serialize, Deserialize)]
pub enum ReactorOutput<O> {
    /// An output message has been received.
    Output(O),
    /// Reactor for current bridge has exited.
    Finish,
}