net.i2p.i2ptunnel.udp
Class I2PSource
java.lang.Object
net.i2p.i2ptunnel.udp.I2PSource
- All Implemented Interfaces:
- java.lang.Runnable, Source
public class I2PSource
- extends java.lang.Object
- implements Source, java.lang.Runnable
- Author:
- welterde
Field Summary |
protected java.util.concurrent.BlockingQueue<java.lang.Integer> |
queue
|
protected boolean |
raw
|
protected I2PSession |
sess
|
protected Sink |
sink
|
protected java.lang.Thread |
thread
|
protected boolean |
verify
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
sess
protected I2PSession sess
queue
protected java.util.concurrent.BlockingQueue<java.lang.Integer> queue
sink
protected Sink sink
thread
protected java.lang.Thread thread
verify
protected boolean verify
raw
protected boolean raw
I2PSource
public I2PSource(I2PSession sess)
I2PSource
public I2PSource(I2PSession sess,
boolean verify)
I2PSource
public I2PSource(I2PSession sess,
boolean verify,
boolean raw)
setSink
public void setSink(Sink sink)
- Specified by:
setSink
in interface Source
start
public void start()
- Specified by:
start
in interface Source
run
public void run()
- Specified by:
run
in interface java.lang.Runnable