Interface GenericOutlet<T>


  • public interface GenericOutlet<T>
    INTERNAL API
    • Method Detail

      • canBePushed

        boolean canBePushed()
      • complete

        void complete()
      • fail

        void fail​(java.lang.Throwable cause)
      • push

        void push​(T elem)
      • setHandler

        void setHandler​(akka.stream.stage.OutHandler handler)