New creates a new instance of the PubSub struct.

Normify is an option that sets the desired normalization options used to normalize/validate the wrp message.

WithEgressHandler is an option that adds a handler for egress messages.

WithEventHandler is an option that adds a handler for event messages.

WithPublishTimeout is an option that sets the timeout for publishing a message.

WithServiceHandler is an option that adds a handler for service messages.

PubSub is a struct representing a publish-subscribe system focusing on wrp messages.

Option is the interface implemented by types that can be used to configure the credentials.

CancelFunc removes the associated listener with and cancels any future events sent to that listener.