@Override
	protected void doStart() {
		try {
			Promise<Void> started = server.start(new ReactorChannelHandler<IN, OUT, ChannelStream<IN, OUT>>() {
				@Override
				public Publisher<Void> apply(ChannelStream<IN, OUT> input) {
					composeChannel(input);

					//never close
					return Streams.never();
				}
			});

			Assert.isTrue(started.awaitSuccess(), "Server did not start properly");
		} catch(InterruptedException e) {
			Thread.currentThread().interrupt();
		}
	}
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