apache_beam.runners.direct.test_stream_impl module

The TestStream implementation for the DirectRunner

The DirectRunner implements TestStream as the _TestStream class which is used to store the events in memory, the _WatermarkController which is used to set the watermark and emit events, and the multiplexer which sends events to the correct tagged PCollection.