ps library

PubSub library.

Simple multilevel Pub/Sub library

Classes

Message

Represents a message that can be published in a topic.

Subscriber

Subscriber can be subscribed to subscription paths

Functions

call(String to, {dynamic data, String? resp, Duration? timeout}) → Future

publish(String to, {dynamic data, String? rpath, bool sticky = false, bool propagate = true}) → int

subscribe(List<String> topics, {bool hidden = false}) → Subscriber

wait(List<String> topics, {bool sticky = true, Duration? timeout}) → Future

Typedefs

MsgCb = void Function(Message msg)

Exceptions / Errors

StackException

Exception that embeds StackTrace so it's not lost on call function