()
| 155 | max_lifetime: null, |
| 156 | fetch_types: false, |
| 157 | onclose() { |
| 158 | Object.entries(listen.channels).forEach(([name, { listeners }]) => { |
| 159 | delete listen.channels[name] |
| 160 | Promise.all(listeners.map(l => listen(name, l.fn, l.onlisten).catch(() => { /* noop */ }))) |
| 161 | }) |
| 162 | }, |
| 163 | onnotify(c, x) { |
| 164 | c in listen.channels && listen.channels[c].listeners.forEach(l => l.fn(x)) |
| 165 | } |