Closed aubi closed 8 months ago
Addition of support for Flow introduced two new methods:
public <T> Subscriber<T> contextualSubscriber(Subscriber<T> subscriber) public <T, R> Processor<T, R> contextualProcessor(Processor<T, R> processor)
This PR implements them.
Addition of support for Flow introduced two new methods:
This PR implements them.