Using Buffer and Promise rather than raw Publisher contracts

PromiseBufferSketch.java

interface Buffer<B> extends Publisher<B> {
	
	<NEWB> Buffer<NEWB> intercept(Interceptor<B, NEWB> fn);

	Buffer<B> append(Buffer<B> buff);

	Buffer<B> append(B obj);

}

interface Promise<T> extends Subscriber<T> {

	boolean isComplete();

	boolean isError();

	T getValue();

	Throwable getCause();
	
	Promise<T> onSuccess(Handler<T> callback);
	
	Promise<T> onError(Handler<Throwable> callback);

}

class Promises {
	
	static <T> Publisher<T> toPublisher(Promise<T> promise);

}

interface Connection {
	
	Buffer<Object> receive();

	Promise<Void> send(Buffer<Object> buff);

}

server
	.intercept(c -> new ConnectionWrapperImpl(c))
	.handler(conn -> {
		conn.receive()
			.intercept(converter::convertToPojo)
			.subscribe(new Subscriber<Pojo>() {});

		Buffer<Pojo> b = pool.alloc(Pojo.class);
		b.append(new Pojo());

		toPublisher(conn.send(b.intercept(convert::convertToBuffer)))
			.subscribe(new Subscriber<Void>() {});
	});