public interface CoreSubscriber<T> extends Subscriber<T>
Contextaware subscriber which has relaxed rules for §1.3 and §3.9 compared to the original
Subscriberfrom Reactive Streams. If an invalid request
<= 0is done on the received subscription, the request will not produce an onError and will simply be ignored.
The rule relaxation has been initially established under reactive-streams-commons.
default Context currentContext()
Contextfrom dependent components which can include downstream operators during subscribing or a terminal
void onSubscribe(Subscription s)
Subscription.request(long). Should further
onNextrelated state modification occur, thread-safety will be required.
Note that an invalid request
<= 0 will not produce an onError and
will simply be ignored or reported through a debug-enabled