@Override
				public Publisher<Void> apply(ChannelStream<IN, OUT> input) {
					composeChannel(input);

					//never close
					return Streams.never();
				}
Inbound ChannelAdapter that uses {@code ReactorPeer} abstraction to provide high-speed TCP or UDP ingest.

@author Stephane Maldini
extensions/spring-xd-extension-reactor/src/main/java/org/springframework/xd/integration/reactor/net/ReactorPeerInboundChannelAdapter.java