Class EngineEventsFluxPublisherFactory
- java.lang.Object
-
- org.activiti.cloud.services.notifications.graphql.subscriptions.datafetcher.EngineEventsFluxPublisherFactory
-
- All Implemented Interfaces:
EngineEventsPublisherFactory
public class EngineEventsFluxPublisherFactory extends Object implements EngineEventsPublisherFactory
-
-
Constructor Summary
Constructors Constructor Description EngineEventsFluxPublisherFactory(reactor.core.publisher.Flux<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsFlux, EngineEventsPredicateFactory predicateFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description reactor.core.publisher.Flux<List<EngineEvent>>getPublisher(graphql.schema.DataFetchingEnvironment environment)
-
-
-
Constructor Detail
-
EngineEventsFluxPublisherFactory
public EngineEventsFluxPublisherFactory(reactor.core.publisher.Flux<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsFlux, EngineEventsPredicateFactory predicateFactory)
-
-
Method Detail
-
getPublisher
public reactor.core.publisher.Flux<List<EngineEvent>> getPublisher(graphql.schema.DataFetchingEnvironment environment)
- Specified by:
getPublisherin interfaceEngineEventsPublisherFactory
-
-