Uses of Interface
com.tick42.glue.core.interop.stream.publish.StreamConsumer
Packages that use StreamConsumer
-
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 StreamConsumerModifier and TypeMethodDescriptionStreamSubscriptionRequest.accept()List<StreamConsumer<?>>StreamBranch.getConsumers()List all consumers on the branch.List<StreamConsumer<?>>StreamProducer.getConsumers()StreamSubscriptionRequestHandler.handle(StreamSubscriptionRequest<T> request) Handle subscription request.default CompletionStage<StreamConsumer<T>>Method parameters in com.tick42.glue.core.interop.stream.publish with type arguments of type StreamConsumerModifier and TypeMethodDescriptiondefault 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)