hstreamdb 0.1.0

Rust client library for HStreamDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::common::Record;
use crate::producer::{self, Request};

#[derive(Clone)]
pub struct Appender {
    request_sender: tokio::sync::mpsc::UnboundedSender<Request>,
}

impl Appender {
    pub(crate) fn new(request_sender: tokio::sync::mpsc::UnboundedSender<Request>) -> Appender {
        Appender { request_sender }
    }
}

impl Appender {
    pub fn append(&mut self, record: Record) -> Result<(), producer::SendError> {
        self.request_sender
            .send(Request(record))
            .map_err(Into::into)
    }
}