1 // This file is generated. Do not edit
2 // @generated
3
4 // https://github.com/Manishearth/rust-clippy/issues/702
5 #![allow(unknown_lints)]
6 #![allow(clippy::all)]
7 #![allow(dead_code)]
8 #![allow(missing_docs)]
9 #![allow(non_camel_case_types)]
10 #![allow(non_snake_case)]
11 #![allow(non_upper_case_globals)]
12 #![allow(trivial_casts)]
13 #![allow(unsafe_code)]
14 #![allow(unused_imports)]
15 #![allow(unused_results)]
16
17 const METHOD_PACKET_STREAMER_STREAM_PACKETS: ::grpcio::Method<
18 super::packet_streamer::PacketRequest,
19 super::packet_streamer::PacketResponse,
20 > = ::grpcio::Method {
21 ty: ::grpcio::MethodType::Duplex,
22 name: "/netsim.packet.PacketStreamer/StreamPackets",
23 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
24 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
25 };
26
27 #[derive(Clone)]
28 pub struct PacketStreamerClient {
29 pub client: ::grpcio::Client,
30 }
31
32 impl PacketStreamerClient {
new(channel: ::grpcio::Channel) -> Self33 pub fn new(channel: ::grpcio::Channel) -> Self {
34 PacketStreamerClient { client: ::grpcio::Client::new(channel) }
35 }
36
stream_packets_opt( &self, opt: ::grpcio::CallOption, ) -> ::grpcio::Result<( ::grpcio::ClientDuplexSender<super::packet_streamer::PacketRequest>, ::grpcio::ClientDuplexReceiver<super::packet_streamer::PacketResponse>, )>37 pub fn stream_packets_opt(
38 &self,
39 opt: ::grpcio::CallOption,
40 ) -> ::grpcio::Result<(
41 ::grpcio::ClientDuplexSender<super::packet_streamer::PacketRequest>,
42 ::grpcio::ClientDuplexReceiver<super::packet_streamer::PacketResponse>,
43 )> {
44 self.client.duplex_streaming(&METHOD_PACKET_STREAMER_STREAM_PACKETS, opt)
45 }
46
stream_packets( &self, ) -> ::grpcio::Result<( ::grpcio::ClientDuplexSender<super::packet_streamer::PacketRequest>, ::grpcio::ClientDuplexReceiver<super::packet_streamer::PacketResponse>, )>47 pub fn stream_packets(
48 &self,
49 ) -> ::grpcio::Result<(
50 ::grpcio::ClientDuplexSender<super::packet_streamer::PacketRequest>,
51 ::grpcio::ClientDuplexReceiver<super::packet_streamer::PacketResponse>,
52 )> {
53 self.stream_packets_opt(::grpcio::CallOption::default())
54 }
spawn<F>(&self, f: F) where F: ::std::future::Future<Output = ()> + Send + 'static,55 pub fn spawn<F>(&self, f: F)
56 where
57 F: ::std::future::Future<Output = ()> + Send + 'static,
58 {
59 self.client.spawn(f)
60 }
61 }
62
63 pub trait PacketStreamer {
stream_packets( &mut self, ctx: ::grpcio::RpcContext, _stream: ::grpcio::RequestStream<super::packet_streamer::PacketRequest>, sink: ::grpcio::DuplexSink<super::packet_streamer::PacketResponse>, )64 fn stream_packets(
65 &mut self,
66 ctx: ::grpcio::RpcContext,
67 _stream: ::grpcio::RequestStream<super::packet_streamer::PacketRequest>,
68 sink: ::grpcio::DuplexSink<super::packet_streamer::PacketResponse>,
69 ) {
70 grpcio::unimplemented_call!(ctx, sink)
71 }
72 }
73
create_packet_streamer<S: PacketStreamer + Send + Clone + 'static>( s: S, ) -> ::grpcio::Service74 pub fn create_packet_streamer<S: PacketStreamer + Send + Clone + 'static>(
75 s: S,
76 ) -> ::grpcio::Service {
77 let mut builder = ::grpcio::ServiceBuilder::new();
78 let mut instance = s;
79 builder = builder.add_duplex_streaming_handler(
80 &METHOD_PACKET_STREAMER_STREAM_PACKETS,
81 move |ctx, req, resp| instance.stream_packets(ctx, req, resp),
82 );
83 builder.build()
84 }
85