Lines Matching refs:EventStream

27 from cert.event_stream import EventStream, FilteringEventStream
133     with EventStream(FetchEvents(events=[1, 2, 3, 1, 2, 3], delay_ms=40)) as event_stream:
139     with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
145         with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
154     with EventStream(FetchEvents(events=[1, 2, 3, 4], delay_ms=50)) as event_stream:
161         with EventStream(FetchEvents(events=[1, 2, 3, 4], delay_ms=50)) as event_stream:
265     with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
270     with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
276         with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
286         with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
295     with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
300     with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
307         with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
317         with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
326     with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
333     with EventStream(FetchEvents(events=[1, 2, 3, 4], delay_ms=400)) as event_stream:
339         with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
348     with EventStream(FetchEvents(events=[], delay_ms=50)) as event_stream:
354     with EventStream(FetchEvents([1], delay_ms=1500)) as event_stream:
360         with EventStream(FetchEvents(events=[17], delay_ms=50)) as event_stream:
369     with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream: