Used by emit_event() to raise new events to the scan
(self, event, **kwargs)
| 1888 | await self.outgoing_event_queue.put((event, kwargs)) |
| 1889 | |
| 1890 | async def queue_outgoing_event(self, event, **kwargs): |
| 1891 | """ |
| 1892 | Used by emit_event() to raise new events to the scan |
| 1893 | """ |
| 1894 | # if this was a normal module, we'd put it in the outgoing queue |
| 1895 | # but because it's an intercept module, we need to queue it at the scan's ingress |
| 1896 | await self.scan.ingress_module.queue_event(event, kwargs) |
| 1897 | |
| 1898 | async def queue_event(self, event, kwargs=None): |
| 1899 | """ |
nothing calls this directly
no test coverage detected