Interface Outputs

    • Method Detail

      • cancel

        void cancel()
      • complete

        void complete()
      • demandAvailable

        boolean demandAvailable()
      • demandCount

        long demandCount()
      • enqueueOutputElement

        void enqueueOutputElement​(java.lang.Object elem)
      • error

        void error​(java.lang.Throwable e)
      • isClosed

        boolean isClosed()
      • isOpen

        boolean isOpen()