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.