Class AgmPeer.StreamFlux<T>
java.lang.Object
com.tick42.glue.internal.gateway.agm.AgmPeer.StreamFlux<T>
- Enclosing interface:
- AgmPeer
public static final class AgmPeer.StreamFlux<T> extends Object
-
Method Summary
Modifier and Type Method Description static <T> AgmPeer.StreamFlux<T>branchStream(String id, reactor.core.publisher.Flux<T> events)static <T> AgmPeer.StreamFlux<T>defaultStream(reactor.core.publisher.Flux<T> events)static <T> AgmPeer.StreamFlux<T>empty()reactor.core.publisher.Flux<T>events()Stringid()booleanisEmpty()
-
Method Details
-
defaultStream
-
branchStream
public static <T> AgmPeer.StreamFlux<T> branchStream(String id, reactor.core.publisher.Flux<T> events) -
empty
-
id
-
isEmpty
public boolean isEmpty() -
events
-