apache_beam.testing.test_stream_service module¶

class apache_beam.testing.test_stream_service.TestStreamServiceController(events, endpoint=None)[source]¶

Bases: apache_beam.portability.api.beam_runner_api_pb2_grpc.TestStreamServiceServicer

start()[source]¶

stop()[source]¶

Events(request, context)[source]¶: Streams back all of the events from the streaming cache.