()
| 950 | |
| 951 | let fired = false; |
| 952 | function finish() { |
| 953 | if (fired) return; |
| 954 | fired = true; |
| 955 | |
| 956 | channel.close(); |
| 957 | target.emit('disconnect'); |
| 958 | } |
| 959 | |
| 960 | // If a message is being read, then wait for it to complete. |
| 961 | if (channel.buffering) { |
no test coverage detected