fs2db 7.3.0

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

use futures::Stream;

use tonic::Status;

pub trait Merge: Send + Sync + 'static {
    type A: Send;
    type B: Send;
    type T: Send;

    fn merge(&self, a: Self::A, b: Self::B) -> Result<Self::T, Status>;
}

#[tonic::async_trait]
pub trait MergeSource: Send + Sync + 'static {
    type K: Send + Sync;
    type V: Send + Sync;

    type All: Stream<Item = Result<(Self::K, Self::V), Status>> + Send + 'static;

    async fn all(&self) -> Result<Self::All, Status>;
}