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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
use crate::{Framing, FramingDecoded, FramingEncodedFinal, Protocol};
use futures::stream::Stream;
use futures::{future, FutureExt};
use std::future::Future;
use std::pin::Pin;
use std::sync::Arc;
pub trait ClientFactory {
type Api: ?Sized;
fn new<P, T>(protocol: P, transport: T) -> Arc<Self::Api>
where
P: Protocol<Frame = T> + 'static,
T: Transport + Sync;
}
pub trait Transport: Framing + Send + 'static {
fn call(
&self,
service_name: &const_cstr::ConstCStr,
fn_name: &const_cstr::ConstCStr,
req: FramingEncodedFinal<Self>,
) -> Pin<Box<dyn Future<Output = Result<FramingDecoded<Self>, anyhow::Error>> + Send + 'static>>;
fn call_stream(
&self,
_service_name: &const_cstr::ConstCStr,
_fn_name: &const_cstr::ConstCStr,
_req: FramingEncodedFinal<Self>,
) -> Pin<
Box<
dyn Future<
Output = Result<
(
FramingDecoded<Self>,
Pin<
Box<
dyn Stream<Item = Result<FramingDecoded<Self>, anyhow::Error>>
+ Send
+ 'static,
>,
>,
),
anyhow::Error,
>,
> + Send
+ 'static,
>,
> {
future::err(anyhow::Error::msg(
"Streaming is not supported by this transport",
))
.boxed()
}
}