apache_beam.testing.test_stream_service module¶

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

Bases: apache_beam.portability.api.org.apache.beam.model.pipeline.v1.beam_runner_api_pb2_grpc.TestStreamServiceServicer

A server that streams TestStreamPayload.Events from a single EventRequest.

This server is used as a way for TestStreams to receive events from file.

start()[source]¶

stop()[source]¶

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