Interface SourceQueueWithComplete<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void complete()
      Complete the stream normally.
      void fail​(java.lang.Throwable ex)
      Complete the stream with a failure.
      scala.concurrent.Future<Done> watchCompletion()
      Method returns a Future that will be completed if this operator completes, or will be failed when the stream fails, for example when SourceQueueWithComplete.fail is invoked.
    • Method Detail

      • complete

        void complete()
        Complete the stream normally. Use watchCompletion to be notified of this operation&rsquo;s success.

        Note that this only means the elements have been passed downstream, not that downstream has successfully processed them.

      • fail

        void fail​(java.lang.Throwable ex)
        Complete the stream with a failure. Use watchCompletion to be notified of this operation&rsquo;s success.
        Parameters:
        ex - (undocumented)
      • watchCompletion

        scala.concurrent.Future<Done> watchCompletion()
        Method returns a Future that will be completed if this operator completes, or will be failed when the stream fails, for example when SourceQueueWithComplete.fail is invoked.

        Note that this only means the elements have been passed downstream, not that downstream has successfully processed them.

        Specified by:
        watchCompletion in interface SourceQueue<T>
        Returns:
        (undocumented)