@repeater/pubusb

This package is experimental!

A generic pubsub class, implemented with repeaters

For more information, visit repeater.js.org.

``ts
interface PubSub {
publish(topic: string, value: T): Promise | void;
unpublish(topic: string, reason?: any): Promise | void;
subscribe(topic: string, buffer?: RepeaterBuffer): AsyncIterableIterator;
close(reason?: any): Promise | void;
}

class InMemoryPubSub implements PubSub {
publish(topic: string, value: T): void;
unpublish(topic: string, reason?: any): void;
subscribe(topic: string, buffer?: RepeaterBuffer): Repeater;
close(reason?: any): void;
}
``