Lines Matching refs:sink
87 fn send_command(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_command()
92 sink.success(Empty::default()).await.unwrap(); in send_command()
98 fn request_event(&mut self, ctx: RpcContext<'_>, req: EventRequest, sink: UnarySink<Empty>) { in request_event()
102 sink.success(Empty::default()).await.unwrap(); in request_event()
110 sink: UnarySink<Empty>, in request_le_subevent()
115 sink.success(Empty::default()).await.unwrap(); in request_le_subevent()
119 fn send_acl(&mut self, ctx: RpcContext<'_>, mut packet: Data, sink: UnarySink<Empty>) { in send_acl()
123 sink.success(Empty::default()).await.unwrap(); in send_acl()
127 fn stream_events(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: ServerStreamingSink<Data>) { in stream_events()
128 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
135 sink: ServerStreamingSink<Data>, in stream_le_subevents()
137 self.le_evt_rx.stream_grpc(ctx, sink); in stream_le_subevents()
140 fn stream_acl(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: ServerStreamingSink<Data>) { in stream_acl()
141 self.acl_rx.stream_grpc(ctx, sink); in stream_acl()