public static interface SubscriberManagement.EndOfStream
<T> void
apply(org.reactivestreams.Subscriber<T> subscriber)
<T> void apply(org.reactivestreams.Subscriber<T> subscriber)