| 200 | recorder = MessageHandlerRecorder() |
| 201 | |
| 202 | class Handlers(object): |
| 203 | @recorder |
| 204 | def stopped_event(self, event): |
| 205 | assert event.event == "stopped" |
| 206 | |
| 207 | @recorder |
| 208 | def event(self, event): |
| 209 | assert event.event == "unknown" |
| 210 | |
| 211 | stream = JsonMemoryStream(EVENTS, []) |
| 212 | channel = messaging.JsonMessageChannel(stream, Handlers()) |
no outgoing calls
searching dependent graphs…