code: func (mux *Multiplexer) Close() {
  	safeclose.Close(
  		mux.Consumer,
  		mux.hashSyncProducer,
  		mux.hashAsyncProducer,
  		mux.manSyncProducer,
  		mux.manAsyncProducer)
  }
docs: // Close cleans up the resources used by the Multiplexer