Lines Matching refs:event_stream

18 from cert.event_stream import EventStream
19 from cert.event_stream import IEventStream
30     def __init__(self, acl_manager, remote_addr, handle, event_stream):  argument
34         self.connection_event_stream = event_stream
79     def complete_connection(self, event_stream):  argument
81         assertThat(event_stream).emits(connection_complete)
85         return PyAclManagerAclConnection(self.acl_manager, address, handle, event_stream)
89         event_stream = self.incoming_connection_event_stream
91         return self.complete_connection(event_stream)
95         event_stream = self.outgoing_connection_event_stream
97         return self.complete_connection(event_stream)