| 57 | |
| 58 | |
| 59 | class Echo(echo_pb2_grpc.EchoServicer): |
| 60 | def EchoMessage(self, request, context): |
| 61 | time.sleep(0.001) |
| 62 | return echo_pb2.EchoReply(message=f"{request.message}") |
| 63 | |
| 64 | def EchoMessageStreaming(self, request_iterator, context): |
| 65 | for request in request_iterator: |
| 66 | yield echo_pb2.EchoReply(message=f"{request.message}") |
| 67 | |
| 68 | |
| 69 | def serve(): |