48 lines
789 B
JavaScript
48 lines
789 B
JavaScript
export class Speaker {
|
|
_callbacks = new Set()
|
|
_scheduled = []
|
|
_retain
|
|
|
|
constructor(...initial) {
|
|
this._retain = initial
|
|
}
|
|
|
|
listen(callback) {
|
|
this._callbacks.add(callback)
|
|
return this._retain
|
|
}
|
|
|
|
speak(...args) {
|
|
if (!this._scheduled.length) {
|
|
queueMicrotask(() => {
|
|
for (let args of this._scheduled) {
|
|
for (let callback of this._callbacks) {
|
|
callback(...args)
|
|
}
|
|
this._retain = args
|
|
}
|
|
this._scheduled = []
|
|
})
|
|
}
|
|
this._scheduled.push(args)
|
|
}
|
|
|
|
forget(callback) {
|
|
this._callbacks.delete(callbacks)
|
|
}
|
|
|
|
silence() {
|
|
this._callbacks.clear()
|
|
}
|
|
}
|
|
|
|
export class ImmediateSpeaker extends Speaker {
|
|
speak(...args) {
|
|
for (let callback of this._callbacks) {
|
|
callback(...args)
|
|
}
|
|
this._retain = args
|
|
}
|
|
}
|
|
|
|
export default Speaker
|