Runnablepublic class SAMv2StreamSession.SAMv2StreamSessionSocketReader extends SAMStreamSession.SAMv1StreamSessionSocketReader
| Modifier and Type | Field | Description |
|---|---|---|
protected long |
limit |
|
protected boolean |
nolimit |
|
protected long |
totalReceived |
i2pSocket, id, runningLock, stillRunning| Constructor | Description |
|---|---|
SAMv2StreamSessionSocketReader(I2PSocket s,
int id) |
Create a new SAM STREAM session socket reader
|
| Modifier and Type | Method | Description |
|---|---|---|
void |
run() |
|
void |
setLimit(long limit,
boolean nolimit) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitstopRunningprotected boolean nolimit
protected long limit
protected long totalReceived
public SAMv2StreamSessionSocketReader(I2PSocket s, int id) throws IOException
s - Socket to be handledid - Unique id assigned to the handlerIOExceptionpublic void setLimit(long limit,
boolean nolimit)
public void run()
run in interface Runnablerun in class SAMStreamSession.SAMv1StreamSessionSocketReader