Processor

Extends both Publisher (Observable) and Subscriber (Observer)

public interface Processor<T, R> extends Subscriber<T>, Publisher <R> {

}