Sketch of Reactive Streams interfaces for Client/Server interaction

ReactiveStreamsIO.java

interface Channel<IN, OUT> extends Publisher<IN> {
	
	Publisher<Boolean> write(Publisher<? extends OUT> data);

}

interface ClientSocketOptions {
	
	SocketAddress connectAddress();

	boolean keepAlive();

	boolean reuseAddress();

	long rvcbuf();
	
	long sndbuf();

}

interface Client<IN, OUT, CHAN extends Channel<IN, OUT>> {
	
	Publisher<CHAN> connect(ClientSocketOptions opts);

	Publisher<CHAN> connect(ClientSocketOptions opts, Publisher<Client<IN, OUT, CHAN>> reconnect);

	Publisher<Boolean> close();

	<I, O, C extends Channel<I, O>> Client<I, O, C> intercept(Function<CHAN, C> fn);

}

interface Server<IN, OUT, CHAN extends Channel<IN, OUT>> {
	
	Publisher<CHAN> start();

	Publisher<CHAN> shutdown();

	<I, O, C extends Channel<I, O>> Server<I, O, C> intercept(Function<CHAN, C> fn);

}