async_nexus

• async_nexus package
  • Submodules
  • async_nexus.boundaries module
    • AsyncEventBoundary
      • AsyncEventBoundary.QUEUE_MAXLEN
      • AsyncEventBoundary.close()
      • AsyncEventBoundary.handle()
      • AsyncEventBoundary.start()
      • AsyncEventBoundary.transfer_events()
  • async_nexus.errors module
    • BadCall
    • InvalidLoopState
    • LoopAlreadyStarted
    • LoopStopped
    • MisconfiguredEventConsumer
    • MisconfiguredEventProducer
    • MultipleStart
    • NoMoreEvents
    • UnhandledEvent
  • async_nexus.zmq module
    • ZmqAbstractConverter
    • ZmqEventConverter
      • ZmqEventConverter.convert_to_event()
      • ZmqEventConverter.obtain_event()
    • ZmqEventReceiver
      • ZmqEventReceiver.obtain_event()
    • ZmqEventSender
      • ZmqEventSender.handle()
    • send_event()
  • Module contents
    • AbstractNexus
      • AbstractNexus.ingest()
    • AsyncEventNexus
      • AsyncEventNexus.QUEUE_MAXLEN
      • AsyncEventNexus.States
      • AsyncEventNexus.add_converter()
      • AsyncEventNexus.add_filter()
      • AsyncEventNexus.add_handler()
      • AsyncEventNexus.add_producer()
      • AsyncEventNexus.cleanup()
      • AsyncEventNexus.ingest()
      • AsyncEventNexus.loop_forever()
      • AsyncEventNexus.register()
      • AsyncEventNexus.start()
      • AsyncEventNexus.stop()
    • AsyncEventPriorityQueue
      • AsyncEventPriorityQueue.get_nowait()
      • AsyncEventPriorityQueue.put()
    • Event
      • Event.id
      • Event.payload
      • Event.priority
      • Event.type
    • EventConsumer
      • EventConsumer.handle()
    • EventConverter
      • EventConverter.close()
      • EventConverter.event_generator()
      • EventConverter.obtain_event()
    • EventDiscarder
      • EventDiscarder.handle()
    • EventDispatcher
    • EventFactory
      • EventFactory.AUTO
      • EventFactory.RANDOM
      • EventFactory.create_event()
      • EventFactory.next_id()
      • EventFactory.random_id()
    • EventFanout
      • EventFanout.deregister()
      • EventFanout.handle()
      • EventFanout.register()
    • EventProducer
      • EventProducer.distribute_event()
      • EventProducer.register_nexus()
      • EventProducer.start()
    • EventSource
      • EventSource.close()
      • EventSource.start()
    • NamedEvent
    • SimpleEventConverter
      • SimpleEventConverter.obtain_event()
    • Timer
      • Timer.COUNT_DOWN
      • Timer.COUNT_UP
      • Timer.ONE_SHOT
      • Timer.ONGOING
      • Timer.create_event()
      • Timer.start()
      • Timer.stop()
    • anext()
    • create_handler_coro()