35     def get_event_queue(self):  argument
41     def __init__(self, stream, filter_fn):  argument
48     def __event_callback(self, event):  argument
51     def get_event_queue(self):  argument
54     def unregister(self):  argument
72     def __init__(self, server_stream_call):  argument
82     def get_event_queue(self):  argument
85     def close(self):  argument
108     def register_callback(self, callback, matcher_fn=None):  argument
130     def unregister_callback(self, callback, matcher_fn=None):  argument
143     def __event_loop(self):  argument
163 …def assert_event_occurs(self, match_fn, at_least_times=1, timeout=timedelta(seconds=DEFAULT_TIMEOU…  argument
176 …def assert_event_occurs_at_most(self, match_fn, at_most_times, timeout=timedelta(seconds=DEFAULT_T…  argument