public static interface Flow.Subscription
Flow.Publisher
Flow.Subscriber
void
cancel()
request(long n)
n
void request(long n)
IllegalArgumentException
onError
onNext
Long.MAX_VALUE
void cancel()
onComplete