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 Details

    • defaultStream

      public static <T> AgmPeer.StreamFlux<T> defaultStream​(reactor.core.publisher.Flux<T> events)
    • branchStream

      public static <T> AgmPeer.StreamFlux<T> branchStream​(String id, reactor.core.publisher.Flux<T> events)
    • empty

      public static <T> AgmPeer.StreamFlux<T> empty()
    • id

      public String id()
    • isEmpty

      public boolean isEmpty()
    • events

      public reactor.core.publisher.Flux<T> events()