Uses of Interface
com.tick42.glue.core.interop.stream.publish.StreamConsumer
-
Packages that use StreamConsumer Package Description com.tick42.glue.core.interop.stream.publish -
-
Uses of StreamConsumer in com.tick42.glue.core.interop.stream.publish
Methods in com.tick42.glue.core.interop.stream.publish that return types with arguments of type StreamConsumer Modifier and Type Method Description CompletionStage<StreamConsumer<T>>StreamSubscriptionRequest. accept()CompletionStage<StreamConsumer<T>>StreamSubscriptionRequest. acceptOn(String branch)List<StreamConsumer<?>>StreamBranch. getConsumers()List all consumers on the branch.List<StreamConsumer<?>>StreamProducer. getConsumers()CompletionStage<StreamConsumer<T>>StreamSubscriptionRequestHandler. handle(StreamSubscriptionRequest<T> request)Handle subscription request.default CompletionStage<StreamConsumer<T>>StreamSubscriptionRequest. reject(String reason)Method parameters in com.tick42.glue.core.interop.stream.publish with type arguments of type StreamConsumer Modifier and Type Method Description default StreamSubscriptionRequestHandler<T>StreamSubscriptionRequestHandler. andThen(Function<? super StreamConsumer<T>,? extends StreamConsumer<T>> fn)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)
-