public class SAMv2StreamSession.SAMv2StreamSessionSocketReader extends SAMStreamSession.SAMv1StreamSessionSocketReader
Modifier and Type | Field and Description |
---|---|
protected long |
limit |
protected boolean |
nolimit |
protected long |
totalReceived |
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() |
void |
setLimit(long limit,
boolean nolimit) |
stopRunning
protected 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 handlerIOException
public void setLimit(long limit, boolean nolimit)
public void run()
run
in interface Runnable
run
in class SAMStreamSession.SAMv1StreamSessionSocketReader