lib/core/process.js
function forceClose(channel) {
    if (!channel) return;

    var destroyer = setTimeout(function () {
      channel.destroy();
    }, 200);

    channel.once('close', function () {
      clearTimeout(destroyer);
    });
  }
function forceClose(channel) {
    if (!channel) return;

    var destroyer = setTimeout(function () {
      channel.destroy();
    }, 200);

    channel.once('close', function () {
      clearTimeout(destroyer);
    });
  }
function forceClose ( channel ) { if ( ! channel ) return ; var destroyer = setTimeout ( function ( ) { channel . destroy ( ) ; } , 200 ) ; channel . once ( 'close' , function ( ) { clearTimeout ( destroyer ) ; } ) ; }
close all streams
close all streams