19 lines
379 B
TypeScript
19 lines
379 B
TypeScript
import {Subject} from "rxjs";
|
|
|
|
interface EmoteEvent {
|
|
userId: number,
|
|
emote: string,
|
|
}
|
|
|
|
class EmoteEventStream {
|
|
|
|
private _stream:Subject<EmoteEvent> = new Subject();
|
|
public stream = this._stream.asObservable();
|
|
|
|
|
|
fire(userId: number, emote:string) {
|
|
this._stream.next({userId, emote});
|
|
}
|
|
}
|
|
|
|
export const emoteEventStream = new EmoteEventStream(); |