Class ClientWriterRunner

  • All Implemented Interfaces:
    Runnable

    class ClientWriterRunner
    extends Object
    implements Runnable
    Copied from net.i2p.router.client We need a single thread that writes so we don't have issues with the Piped Streams used in InternalSocket.
    Author:
    zzz from net.i2p.router.client.ClientWriterRunner
    • Constructor Detail

      • ClientWriterRunner

        public ClientWriterRunner​(OutputStream out,
                                  I2PSessionImpl session)
        As of 0.9.11 does not start the thread, caller must call startWriting()
    • Method Detail

      • startWriting

        public void startWriting()
        Since:
        0.9.11
      • stopWriting

        public void stopWriting()
        No more messages - dont even try to send what we have
      • run

        public void run()
        Specified by:
        run in interface Runnable