net.i2p.sam
protected class SAMStreamSession.StreamSender extends Object implements Runnable
Constructor and Description |
---|
SAMStreamSession.StreamSender(I2PSocket s,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
void |
sendBytes(InputStream in,
int size)
Send bytes through the SAM STREAM session socket sender
|
void |
shutDownGracefully()
Stop a SAM STREAM session socket sender gracefully: stop the
sender thread once all pending data has been sent.
|
void |
stopRunning()
Stop a SAM STREAM session socket sender thread immediately
|
public SAMStreamSession.StreamSender(I2PSocket s, int id) throws IOException
IOException
public void sendBytes(InputStream in, int size) throws IOException
in
- Data input streamsize
- Count of bytes to sendIOException
- if the client didnt provide enough datapublic void stopRunning()
public void shutDownGracefully()