(fn: (messageID: string) => boolean | Promise<boolean>)
| 369 | } |
| 370 | |
| 371 | public onQueuedRemove(fn: (messageID: string) => boolean | Promise<boolean>): () => void { |
| 372 | this.queuedRemoves.add(fn) |
| 373 | return () => { |
| 374 | this.queuedRemoves.delete(fn) |
| 375 | } |
| 376 | } |
| 377 | |
| 378 | public onClose(fn: () => void): () => void { |
| 379 | if (this.isClosed) { |
no test coverage detected