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)