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)