net.i2p.BOB
Class TCPio

java.lang.Object
  extended by net.i2p.BOB.TCPio
All Implemented Interfaces:
java.lang.Runnable

public class TCPio
extends java.lang.Object
implements java.lang.Runnable

Shove data from one stream to the other.

Author:
sponge

Constructor Summary
TCPio(java.io.InputStream Ain, java.io.OutputStream Aout, java.util.concurrent.atomic.AtomicBoolean lives)
          Constructor
 
Method Summary
 void run()
          Copy from source to destination...
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TCPio

TCPio(java.io.InputStream Ain,
      java.io.OutputStream Aout,
      java.util.concurrent.atomic.AtomicBoolean lives)
Constructor

Parameters:
Ain - InputStream
Aout - OutputStream param database
Method Detail

run

public void run()
Copy from source to destination... and yes, we are totally OK to block here on writes, The OS has buffers, and I intend to use them. We send an interrupt signal to the threadgroup to unwedge any pending writes.

Specified by:
run in interface java.lang.Runnable