Uses of Interface
com.tick42.glue.core.interop.stream.publish.StreamSubscriptionRequestHandler
-
Packages that use StreamSubscriptionRequestHandler Package Description com.tick42.glue.core.interop Interop API .com.tick42.glue.core.interop.stream.publish -
-
Uses of StreamSubscriptionRequestHandler in com.tick42.glue.core.interop
Methods in com.tick42.glue.core.interop with parameters of type StreamSubscriptionRequestHandler Modifier and Type Method Description <T> CompletionStage<StreamProducer>Interop. 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 StreamSubscriptionRequestHandler Modifier and Type Method Description static <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)
-