Package 

Class BaseStreamReceiver

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private final Flow<T> flow

    • Method Summary

      Modifier and Type Method Description
      abstract Flow<T> getFlow()
      final T readNext() Suspends and waits for the next piece of data.
      final List<T> readAll() Suspends and waits for all available data until the stream is closed.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • BaseStreamReceiver

        BaseStreamReceiver(Channel<ByteArray> source)

    • Method Detail

      • readNext

         final T readNext()

        Suspends and waits for the next piece of data.

      • readAll

         final List<T> readAll()

        Suspends and waits for all available data until the stream is closed.