Uses of Interface
com.tick42.glue.core.interop.stream.publish.StreamSubscriptionRequestHandler
Packages that use StreamSubscriptionRequestHandler
Package
Description
Interop API .
-
Uses of StreamSubscriptionRequestHandler in com.tick42.glue.core.interop
Methods in com.tick42.glue.core.interop with parameters of type StreamSubscriptionRequestHandlerModifier and TypeMethodDescriptionInterop.register(MethodDefinition method, StreamSubscriptionRequestHandler<T> handler) -
Uses of StreamSubscriptionRequestHandler in com.tick42.glue.core.interop.stream.publish
Methods in com.tick42.glue.core.interop.stream.publish that return StreamSubscriptionRequestHandlerModifier and TypeMethodDescriptionstatic <T> StreamSubscriptionRequestHandler<T>StreamSubscriptionRequestHandler.accept()Returns aStreamSubscriptionRequestHandlerthat accepts all subscription request and subscribes them to the default stream.static <T> StreamSubscriptionRequestHandler<T>StreamSubscriptionRequestHandler.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>StreamSubscriptionRequestHandler.andThen(Function<? super StreamConsumer<T>, ? extends StreamConsumer<T>> fn) default StreamSubscriptionRequestHandler<T>StreamSubscriptionRequestHandler.onAdded(Consumer<? super StreamConsumer<T>> subscriptionAdded) default StreamSubscriptionRequestHandler<T>StreamSubscriptionRequestHandler.onRemoved(Consumer<? super StreamConsumer<T>> subscriptionRemoved)