this.channels.values()
            .forEach(({source, target}: { source: Pipe, target?: Pipe }) => {
                if (source) {
                    source.close();
                }