PubSub broker powered by Redis
Example
Extends
BaseRedisBroker<TEvents>Implements
IPubSubBroker<TEvents>Whether this broker is currently polling events
Options this broker is using
Inherited from BaseRedisBroker
Used for Redis queues, see the 3rd argument taken by xadd
Internal copy of the Redis client being used to read incoming payloads
Events this broker has subscribed to
Destroys the broker, closing all connections
Begins polling for events, firing them to listen
Publishes an event
Name | Constraints | Optional | Default | Description |
---|---|---|---|---|
Event | keyof TEvents | No | None |
Name | Type | Optional | Description |
---|---|---|---|
event | Event | No | None |
data | TEvents[Event] | No | None |
Subscribes to the given events
Name | Type | Optional | Description |
---|---|---|---|
events | (keyof TEvents)[] | No | None |
Unsubscribes from the given events
Name | Type | Optional | Description |
---|---|---|---|
events | (keyof TEvents)[] | No | None |