Class LocalOutputConnectionHandler

    • Field Detail

      • maxstored

        protected int maxstored
        The maximum bytes of data that can be stored in connection (without being consumed).
      • readyfuture

        protected Future<java.lang.Integer> readyfuture
        The ready future.
    • Constructor Detail

      • LocalOutputConnectionHandler

        public LocalOutputConnectionHandler​(java.util.Map<java.lang.String,​java.lang.Object> nonfunc)
      • LocalOutputConnectionHandler

        public LocalOutputConnectionHandler​(java.util.Map<java.lang.String,​java.lang.Object> nonfunc,
                                            LocalAbstractConnectionHandler conhandler)
    • Method Detail

      • waitForReady

        public IFuture<java.lang.Integer> waitForReady()
        Wait until the connection is ready for the next write.
        Specified by:
        waitForReady in interface IOutputConnectionHandler
        Returns:
        Calls future when next data can be written.
      • ready

        public void ready​(int available)
        Called by local input connection handler to signal that user has read some data.