Struct Writer 

pub struct Writer {
    host: Host,
    store: Store,
    connections: HashMap<ConnectionId, Outbox>,
    next_connection: u64,
}

Fields

host: Host

store: Store

connections: HashMap<ConnectionId, Outbox>

next_connection: u64

Implementations

impl Writer

pub fn new(host: Host, store: Store) -> Self

pub async fn run(self, requests: UnboundedReceiver<Request>)

fn connect(&mut self, outbox: Outbox, reply: Sender<ConnectionId>)

fn submit(&mut self, from: ConnectionId, nonce: Nonce, envelope: CommitEnvelope)

fn send(&self, to: ConnectionId, message: &ServerMsg)