apache_beam.portability.api.beam_runner_api_pb2_grpc module¶

class apache_beam.portability.api.beam_runner_api_pb2_grpc.TestStreamServiceStub(channel)[source]¶

Bases: future.types.newobject.newobject

Constructor.

Parameters:	channel – A grpc.Channel.

class apache_beam.portability.api.beam_runner_api_pb2_grpc.TestStreamServiceServicer[source]¶

Bases: future.types.newobject.newobject

Events(request, context)[source]¶: A TestStream will request for events using this RPC.

apache_beam.portability.api.beam_runner_api_pb2_grpc.add_TestStreamServiceServicer_to_server(servicer, server)[source]¶