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.