grpc unary-stream client

gistfile1.txt

import grpc

from gridarrow.api_v1.proto.api_pb2 import ApplicationStreamRequest
from gridarrow.api_v1.proto.api_pb2_grpc import StreamsStub


def run():
    channel = grpc.insecure_channel('localhost:50051')
    stub = StreamsStub(channel)

    stream = stub.Application(ApplicationStreamRequest())
    try:
        for e in stream:
            print(e)
    except KeyboardInterrupt:
        pass


if __name__ == "__main__":
    run()