Add process() method to Publisher.

[ldaley]

It seems that Processor would be a lot more useful if it supported chaining. This could be done by adding the following to Publisher:

interface Publisher<T> {  
  <R> process(Processor<? super T, ? extends R> processor);
}

It would be boilerplate for implementors to support, but I don't think that's a problem.

[viktorklang]

What's wrong with publisher.subscribe(processor)?

[ldaley]

What's wrong with publisher.subscribe(processor)?

Doesn't support chaining, which is the point of my proposal.

Also, keep in mind that the RS interfaces is for interoperability, not for end-user APIs.

Then what's the point of having Processor at all? I can't see any value to it if it's just about interop.

[viktorklang]

@alkemist That's a whole other discussion, I'd recommend to go through the closed issues, they contain a lot of the rationale and decisions, in this case: #22

[ldaley]

I don't have anything to add that hasn't already been said in that issue.