32     def __init__(self, value):  argument
33         self._value = value
35     def isEqualTo(self, other):  argument
36         if self._value != other:
37 …raise signals.TestFailure("Expected \"%s\" to be equal to \"%s\"" % (self._value, other), extras=N…
39     def isNotEqualTo(self, other):  argument
40         if self._value == other:
41 …raise signals.TestFailure("Expected \"%s\" to not be equal to \"%s\"" % (self._value, other), extr…
43     def isNone(self):  argument
44         if self._value is not None:
45             raise signals.TestFailure("Expected \"%s\" to be None" % self._value, extras=None)
47     def isNotNone(self):  argument
48         if self._value is None:
49             raise signals.TestFailure("Expected \"%s\" to not be None" % self._value, extras=None)
57     def __init__(self, value):  argument
60     def emits(self, *match_fns, at_least_times=1, timeout=DEFAULT_TIMEOUT):  argument
64 …NOT_FOR_YOU_assert_event_occurs(self._value, match_fns[0], at_least_times=at_least_times, timeout=…
65             return EventStreamContinuationSubject(self._value)
67             return MultiMatchStreamSubject(self._value, match_fns, timeout)
69     def emitsNone(self, *match_fns, timeout=DEFAULT_TIMEOUT):  argument
71             NOT_FOR_YOU_assert_none(self._value, timeout=timeout)
72             return EventStreamContinuationSubject(self._value)
74             NOT_FOR_YOU_assert_none_matching(self._value, match_fns[0], timeout=timeout)
75             return EventStreamContinuationSubject(self._value)
82     def __init__(self, stream, match_fns, timeout):  argument
83         self._stream = stream
84         self._match_fns = match_fns
85         self._timeout = timeout
87     def inAnyOrder(self):  argument
88 …NOT_FOR_YOU_assert_all_events_occur(self._stream, self._match_fns, order_matters=False, timeout=se…
89         return EventStreamContinuationSubject(self._stream)
91     def inOrder(self):  argument
92 …NOT_FOR_YOU_assert_all_events_occur(self._stream, self._match_fns, order_matters=True, timeout=sel…
93         return EventStreamContinuationSubject(self._stream)
98     def __init__(self, value):  argument
101     def then(self, *match_fns, at_least_times=1, timeout=DEFAULT_TIMEOUT):  argument
105 …NOT_FOR_YOU_assert_event_occurs(self._value, match_fns[0], at_least_times=at_least_times, timeout=…
106             return EventStreamContinuationSubject(self._value)
108             return MultiMatchStreamSubject(self._value, match_fns, timeout)
110     def thenNone(self, *match_fns, timeout=DEFAULT_TIMEOUT):  argument
112             NOT_FOR_YOU_assert_none(self._value, timeout=timeout)
113             return EventStreamContinuationSubject(self._value)
115             NOT_FOR_YOU_assert_none_matching(self._value, match_fns[0], timeout=timeout)
116             return EventStreamContinuationSubject(self._value)
123     def __init__(self, value):  argument
126     def isTrue(self):  argument
127         assert_true(self._value, "")
129     def isFalse(self):  argument
130         assert_false(self._value, "")
135     def __init__(self, value):  argument
138     def isWithin(self, time_bound):  argument
139         assert_true(self._value < time_bound, "")