Lines Matching refs:sink

50     fn send_command(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) {  in send_command()
54             sink.success(Empty::default()).await.unwrap();  in send_command()
58     fn send_acl(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) {  in send_acl()
62             sink.success(Empty::default()).await.unwrap();  in send_acl()
70     fn send_iso(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) {  in send_iso()
74             sink.success(Empty::default()).await.unwrap();  in send_iso()
78     fn stream_events(&mut self, ctx: RpcContext<'_>, _: Empty, sink: ServerStreamingSink<Data>) {  in stream_events()
79         self.evt_rx.stream_grpc(ctx, sink);  in stream_events()
82     fn stream_acl(&mut self, ctx: RpcContext<'_>, _: Empty, sink: ServerStreamingSink<Data>) {  in stream_acl()
83         self.acl_rx.stream_grpc(ctx, sink);  in stream_acl()
90     fn stream_iso(&mut self, ctx: RpcContext<'_>, _: Empty, sink: ServerStreamingSink<Data>) {  in stream_iso()
91         self.iso_rx.stream_grpc(ctx, sink);  in stream_iso()