Class ApplicationThreadDeframer.InitializingMessageProducer

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private boolean initialized  
      private java.lang.Runnable runnable  
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      private InitializingMessageProducer​(java.lang.Runnable runnable)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      private void initialize()  
      java.io.InputStream next()
      Returns the next gRPC message, if the data has been received by the deframer and the application has requested another message.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • runnable

        private final java.lang.Runnable runnable
      • initialized

        private boolean initialized
    • Constructor Detail

      • InitializingMessageProducer

        private InitializingMessageProducer​(java.lang.Runnable runnable)
    • Method Detail

      • initialize

        private void initialize()
      • next

        @Nullable
        public java.io.InputStream next()
        Description copied from interface: StreamListener.MessageProducer
        Returns the next gRPC message, if the data has been received by the deframer and the application has requested another message.

        The provided message InputStream must be closed by the listener.

        This is intended to be used similar to an iterator, invoking next() to obtain messages until the producer returns null, at which point the producer may be discarded.

        Specified by:
        next in interface StreamListener.MessageProducer