public class SAMv2StreamSession.SAMv2StreamSessionSocketReader extends SAMStreamSession.SAMv1StreamSessionSocketReader
| Modifier and Type | Field and Description |
|---|---|
protected long | limitlimit. |
protected boolean | nolimitnolimit. |
protected long | totalReceivedtotalReceived. |
i2pSocket, id, runningLock, stillRunning| Constructor and Description |
|---|
SAMv2StreamSessionSocketReader(I2PSocket s,
int id)Create a new SAM STREAM session socket reader |
| Modifier and Type | Method and Description |
|---|---|
void | run()run. |
void | setLimit(long limit,
boolean nolimit)setLimit. |
stopRunningprotected long limit
protected boolean nolimit
protected long totalReceived
public SAMv2StreamSessionSocketReader(I2PSocket s, int id) throws IOException
s - Socket to be handledid - Unique id assigned to the handlerIOExceptionpublic void run()
run in interface Runnablerun in class SAMStreamSession.SAMv1StreamSessionSocketReaderpublic void setLimit(long limit,
boolean nolimit)