(feeds, inboxes, messages)
| 104 | |
| 105 | |
| 106 | def sample_pubsub(feeds, inboxes, messages): |
| 107 | feed_map, inbox_map = setup_topology(feeds, inboxes) |
| 108 | run_threads(feed_map, inbox_map, messages) |
| 109 | |
| 110 | |
| 111 | if __name__ == "__main__": |
no test coverage detected