1# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 2import grpc 3 4import huawei_grpc_dialout_pb2 as huawei__grpc__dialout__pb2 5 6 7class gRPCDataserviceStub(object): 8 # missing associated documentation comment in .proto file 9 pass 10 11 def __init__(self, channel): 12 """Constructor. 13 14 Args: 15 channel: A grpc.Channel. 16 """ 17 self.dataPublish = channel.stream_stream( 18 '/huawei_dialout.gRPCDataservice/dataPublish', 19 request_serializer=huawei__grpc__dialout__pb2.serviceArgs.SerializeToString, 20 response_deserializer=huawei__grpc__dialout__pb2.serviceArgs.FromString, 21 ) 22 23 24class gRPCDataserviceServicer(object): 25 # missing associated documentation comment in .proto file 26 pass 27 28 def dataPublish(self, request_iterator, context): 29 # missing associated documentation comment in .proto file 30 pass 31 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 32 context.set_details('Method not implemented!') 33 raise NotImplementedError('Method not implemented!') 34 35 36def add_gRPCDataserviceServicer_to_server(servicer, server): 37 rpc_method_handlers = { 38 'dataPublish': grpc.stream_stream_rpc_method_handler( 39 servicer.dataPublish, 40 request_deserializer=huawei__grpc__dialout__pb2.serviceArgs.FromString, 41 response_serializer=huawei__grpc__dialout__pb2.serviceArgs.SerializeToString, 42 ), 43 } 44 generic_handler = grpc.method_handlers_generic_handler( 45 'huawei_dialout.gRPCDataservice', rpc_method_handlers) 46 server.add_generic_rpc_handlers((generic_handler,)) 47