Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 | 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 1x 1x 1x 1x 1x 1x | export default class Observable {
constructor() {
this.observers = new Map()
this.errors = new Map()
this.completes = new Map()
}
subscribe(f) {
let complete, error, next = f
Eif (typeof f !== 'function') {
({ next, error, complete } = f)
}
const uid = new Date().getTime().toString(36) + performance.now().toString().replace(/[^0-9]/g, '')
Eif (next) {
this.observers.set(uid, next)
}
Eif (error) {
this.errors.set(uid, error)
}
Eif (complete) {
this.completes.set(uid, complete)
}
return { uid, unsubscribe: this.unsubscribe.bind(this, uid) }
}
unsubscribe(uid) {
this.observers.delete(uid)
this.errors.delete(uid)
}
complete() {
this.completes.forEach(observer => observer())
this.observers = new Map()
this.errors = new Map()
this.completes = new Map()
}
notify(msg) {
this.observers.forEach(observer => observer(msg))
}
notifyError(msg) {
this.errors.forEach(observer => observer(msg))
}
}
|