code: public RemoteInputChannel toRemoteInputChannel(ConnectionID producerAddress) {
  		return new RemoteInputChannel(inputGate, channelIndex, partitionId, checkNotNull(producerAddress), connectionManager, initialBackoff, maxBackoff, metrics);
  	}
docs: ------------------------------------------------------------------------