@Override
			public void accept(IN in) {
				sendMessage(new GenericMessage<Object>(in));
			}
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