mirror of
https://github.com/BlowaterNostr/blowater.git
synced 2024-10-18 07:33:22 +00:00
55d6735e7b
and remove submodules
24 lines
561 B
TypeScript
24 lines
561 B
TypeScript
import { chan, Channel, multi } from "@blowater/csp";
|
|
|
|
export class EventBus<T> implements EventEmitter<T>, EventSubscriber<T> {
|
|
private readonly c = chan<T>();
|
|
private readonly caster = multi<T>(this.c);
|
|
|
|
emit = async (event: T) => {
|
|
await this.c.put(event);
|
|
};
|
|
|
|
onChange() {
|
|
return this.caster.copy();
|
|
}
|
|
}
|
|
|
|
export type EventEmitter<T> = {
|
|
emit: (event: T) => void;
|
|
};
|
|
export type emitFunc<T extends { type: string }> = (event: T) => Promise<void>;
|
|
|
|
export type EventSubscriber<T> = {
|
|
onChange(): Channel<T>;
|
|
};
|