fidl_next_bind/
service.rs1use core::marker::PhantomData;
6use core::ops::Deref;
7
8use fidl_next_protocol::ServiceHandler;
9
10pub trait DiscoverableService {
12 const SERVICE_NAME: &'static str;
14 const MEMBER_NAMES: &'static [&'static str];
16}
17
18pub trait Service<C>: DiscoverableService {
24 type Connector;
26}
27
28#[repr(transparent)]
30pub struct ServiceConnector<S, C> {
31 connector: C,
32 service: PhantomData<S>,
33}
34
35unsafe impl<S, C: Send> Send for ServiceConnector<S, C> {}
36unsafe impl<S, C: Sync> Sync for ServiceConnector<S, C> {}
37
38impl<S, C> ServiceConnector<S, C> {
39 pub fn from_untyped(connector: C) -> Self {
41 Self { connector, service: PhantomData }
42 }
43}
44
45impl<S: Service<C>, C> Deref for ServiceConnector<S, C> {
46 type Target = S::Connector;
47
48 fn deref(&self) -> &Self::Target {
49 unsafe { &*(self as *const Self).cast::<S::Connector>() }
51 }
52}
53
54pub trait DispatchServiceHandler<
56 H,
57 #[cfg(feature = "fuchsia")] T = zx::Channel,
58 #[cfg(not(feature = "fuchsia"))] T,
59>
60{
61 fn on_connection(handler: &H, member: &str, server_end: T);
63}
64
65pub struct ServiceHandlerAdapter<S, H> {
67 handler: H,
68 _service: PhantomData<S>,
69}
70
71impl<S, H: Clone> Clone for ServiceHandlerAdapter<S, H> {
72 fn clone(&self) -> Self {
73 Self { handler: self.handler.clone(), _service: PhantomData }
74 }
75}
76
77unsafe impl<S, H> Send for ServiceHandlerAdapter<S, H> where H: Send {}
78unsafe impl<S, H> Sync for ServiceHandlerAdapter<S, H> where H: Sync {}
79
80impl<S, H> ServiceHandlerAdapter<S, H> {
81 pub fn from_untyped(handler: H) -> Self {
83 Self { handler, _service: PhantomData }
84 }
85}
86
87impl<S, H, T> ServiceHandler<T> for ServiceHandlerAdapter<S, H>
88where
89 S: DispatchServiceHandler<H, T>,
90{
91 fn on_connection(&self, member: &str, server_end: T) {
92 S::on_connection(&self.handler, member, server_end)
93 }
94}