apache_beam.testing.test_stream_service module¶

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

Bases: 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.