Interface StreamSubscriptionRequestHandler<T>
- Type Parameters:
T- type of the subscription request argument
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
Handler for subscription requests.
-
Method Summary
Modifier and TypeMethodDescriptionstatic <T> StreamSubscriptionRequestHandler<T>accept()Returns aStreamSubscriptionRequestHandlerthat accepts all subscription request and subscribes them to the default stream.static <T> StreamSubscriptionRequestHandler<T>accept(BiFunction<T, Instance, String> streamFunction) Returns aStreamSubscriptionRequestHandlerthat accepts all subscription request and subscribes them to a stream with id returned by the providedstreamFunction.apply(arg, caller).default StreamSubscriptionRequestHandler<T>andThen(Function<? super StreamConsumer<T>, ? extends StreamConsumer<T>> fn) handle(StreamSubscriptionRequest<T> request) Handle subscription request.default StreamSubscriptionRequestHandler<T>onAdded(Consumer<? super StreamConsumer<T>> subscriptionAdded) default StreamSubscriptionRequestHandler<T>onRemoved(Consumer<? super StreamConsumer<T>> subscriptionRemoved)
-
Method Details
-
accept
Returns aStreamSubscriptionRequestHandlerthat accepts all subscription request and subscribes them to the default stream.- Type Parameters:
T- type of the subscription request argument- Returns:
- a subscription request handler, never
null
-
accept
Returns aStreamSubscriptionRequestHandlerthat accepts all subscription request and subscribes them to a stream with id returned by the providedstreamFunction.apply(arg, caller).- Type Parameters:
T- type of the subscription request argument- Parameters:
streamFunction- function that accepts requestargandcallerinstance and returns stream id- Returns:
- a subscription request handler, never
null
-
handle
Handle subscription request.The request can be
accepted (on main stream),accepted on streamorrejected.- Parameters:
request- subscription request to handle- Returns:
- a stage that completes with a
StreamConsumerwhen the request is accepted and completes exceptionally with aStreamSubscriptionRejectedExceptionwhen the request is rejected
-
onAdded
default StreamSubscriptionRequestHandler<T> onAdded(Consumer<? super StreamConsumer<T>> subscriptionAdded) -
onRemoved
default StreamSubscriptionRequestHandler<T> onRemoved(Consumer<? super StreamConsumer<T>> subscriptionRemoved) -
andThen
default StreamSubscriptionRequestHandler<T> andThen(Function<? super StreamConsumer<T>, ? extends StreamConsumer<T>> fn)
-