@Override
	protected void doStop() {
		try {
			Assert.isTrue(server.shutdown().awaitSuccess(), "Server did not shutdown 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