Storing message receiver.
Receives arrays of discard reason and discarded message. Stores all
messages to inbox.
Optionally provide Inbox instance. Defaults to new FifoInbox
instance.
-
class
receiver.store.StoreReceiver(inbox=<fifo>)
| Arguments: |
- inbox (function) – Inbox to deliver messages to. Defaults to new FIFO inbox.
|
|---|
-
receiver.store.StoreReceiver.submit(message)
| Arguments: |
- *> message (Array.<Error,) – Discard reason and discarded message.
|
|---|