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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
use std::ffi::CStr;
use std::sync::Arc;
use futures::future;
use futures::future::BoxFuture;
use futures::stream::BoxStream;
use futures::FutureExt;
use crate::help::Spawner;
use crate::Framing;
use crate::FramingDecoded;
use crate::FramingEncodedFinal;
use crate::Protocol;
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,
P::Deserializer: Send,
{
let spawner = crate::NoopSpawner;
Self::with_spawner(protocol, transport, spawner)
}
fn with_spawner<P, T, S>(protocol: P, transport: T, spawner: S) -> Arc<Self::Api>
where
P: Protocol<Frame = T> + 'static,
T: Transport,
P::Deserializer: Send,
S: Spawner;
}
pub trait Transport: Framing + Send + Sync + Sized + 'static {
type RpcOptions: Default;
fn call(
&self,
service_name: &'static CStr,
fn_name: &'static CStr,
req: FramingEncodedFinal<Self>,
rpc_options: Self::RpcOptions,
) -> BoxFuture<'static, anyhow::Result<FramingDecoded<Self>>>;
fn call_stream(
&self,
_service_name: &'static CStr,
_fn_name: &'static CStr,
_req: FramingEncodedFinal<Self>,
_rpc_options: Self::RpcOptions,
) -> BoxFuture<
'static,
anyhow::Result<(
FramingDecoded<Self>,
BoxStream<'static, anyhow::Result<FramingDecoded<Self>>>,
)>,
> {
future::err(anyhow::Error::msg(
"Streaming is not supported by this transport",
))
.boxed()
}
fn create_interaction(&self, _method_name: &'static CStr) -> Result<Self, anyhow::Error> {
anyhow::bail!("Interactions are not supported by this transport");
}
}