Uses of Interface
java.util.concurrent.Flow.Subscriber
Packages that use Flow.Subscriber
Package
Description
HTTP Client and WebSocket APIs
Utility classes commonly useful in concurrent programming.
-
Uses of Flow.Subscriber in java.net.http
Subinterfaces of Flow.Subscriber in java.net.httpModifier and TypeInterfaceDescriptionstatic interfaceABodySubscriberconsumes response body bytes and converts them into a higher-level Java type.Methods in java.net.http with type parameters of type Flow.SubscriberModifier and TypeMethodDescriptionstatic <S extends Flow.Subscriber<? super String>,T>
HttpResponse.BodyHandler<T>HttpResponse.BodyHandlers.fromLineSubscriber(S subscriber, Function<? super S, ? extends T> finisher, String lineSeparator) Returns a response body handler that returns aBodySubscriber<T>obtained fromBodySubscribers.fromLineSubscriber(subscriber, finisher, charset, lineSeparator), with the givensubscriber,finisherfunction, and line separator.static <S extends Flow.Subscriber<? super String>,T>
HttpResponse.BodySubscriber<T>HttpResponse.BodySubscribers.fromLineSubscriber(S subscriber, Function<? super S, ? extends T> finisher, Charset charset, String lineSeparator) Returns a body subscriber that forwards all response body to the givenFlow.Subscriber, line by line.static <S extends Flow.Subscriber<? super List<ByteBuffer>>,T>
HttpResponse.BodyHandler<T>HttpResponse.BodyHandlers.fromSubscriber(S subscriber, Function<? super S, ? extends T> finisher) Returns a response body handler that returns aBodySubscriber<T>obtained fromHttpResponse.BodySubscribers.fromSubscriber(Subscriber, Function), with the givensubscriberandfinisherfunction.static <S extends Flow.Subscriber<? super List<ByteBuffer>>,T>
HttpResponse.BodySubscriber<T>HttpResponse.BodySubscribers.fromSubscriber(S subscriber, Function<? super S, ? extends T> finisher) Returns a body subscriber that forwards all response body to the givenFlow.Subscriber.Methods in java.net.http with parameters of type Flow.SubscriberModifier and TypeMethodDescriptionstatic HttpResponse.BodyHandler<Void>HttpResponse.BodyHandlers.fromLineSubscriber(Flow.Subscriber<? super String> subscriber) Returns a response body handler that returns aBodySubscriber<Void>obtained fromBodySubscribers.fromLineSubscriber(subscriber, s -> null, charset, null), with the givensubscriber.static HttpResponse.BodySubscriber<Void>HttpResponse.BodySubscribers.fromLineSubscriber(Flow.Subscriber<? super String> subscriber) Returns a body subscriber that forwards all response body to the givenFlow.Subscriber, line by line.static HttpResponse.BodyHandler<Void>HttpResponse.BodyHandlers.fromSubscriber(Flow.Subscriber<? super List<ByteBuffer>> subscriber) Returns a response body handler that returns aBodySubscriber<Void>obtained fromHttpResponse.BodySubscribers.fromSubscriber(Subscriber), with the givensubscriber.static HttpResponse.BodySubscriber<Void>HttpResponse.BodySubscribers.fromSubscriber(Flow.Subscriber<? super List<ByteBuffer>> subscriber) Returns a body subscriber that forwards all response body to the givenFlow.Subscriber. -
Uses of Flow.Subscriber in java.util.concurrent
Subinterfaces of Flow.Subscriber in java.util.concurrentModifier and TypeInterfaceDescriptionstatic interfaceFlow.Processor<T,R> A component that acts as both a Subscriber and Publisher.Methods in java.util.concurrent that return types with arguments of type Flow.SubscriberModifier and TypeMethodDescriptionList<Flow.Subscriber<? super T>>SubmissionPublisher.getSubscribers()Returns a list of current subscribers for monitoring and tracking purposes, not for invokingFlow.Subscribermethods on the subscribers.Methods in java.util.concurrent with parameters of type Flow.SubscriberModifier and TypeMethodDescriptionbooleanSubmissionPublisher.isSubscribed(Flow.Subscriber<? super T> subscriber) Returns true if the given Subscriber is currently subscribed.voidFlow.Publisher.subscribe(Flow.Subscriber<? super T> subscriber) Adds the given Subscriber if possible.voidSubmissionPublisher.subscribe(Flow.Subscriber<? super T> subscriber) Adds the given Subscriber unless already subscribed.Method parameters in java.util.concurrent with type arguments of type Flow.SubscriberModifier and TypeMethodDescriptionintSubmissionPublisher.offer(T item, long timeout, TimeUnit unit, BiPredicate<Flow.Subscriber<? super T>, ? super T> onDrop) Publishes the given item, if possible, to each current subscriber by asynchronously invoking itsonNextmethod, blocking while resources for any subscription are unavailable, up to the specified timeout or until the caller thread is interrupted, at which point the given handler (if non-null) is invoked, and if it returns true, retried once.intSubmissionPublisher.offer(T item, BiPredicate<Flow.Subscriber<? super T>, ? super T> onDrop) Publishes the given item, if possible, to each current subscriber by asynchronously invoking itsonNextmethod.Constructor parameters in java.util.concurrent with type arguments of type Flow.SubscriberModifierConstructorDescriptionSubmissionPublisher(Executor executor, int maxBufferCapacity, BiConsumer<? super Flow.Subscriber<? super T>, ? super Throwable> handler) Creates a new SubmissionPublisher using the given Executor for async delivery to subscribers, with the given maximum buffer size for each subscriber, and, if non-null, the given handler invoked when any Subscriber throws an exception in methodonNext.