java.lang.Runnableprotected abstract static class SAMStreamSession.StreamSender
extends java.lang.Object
implements java.lang.Runnable
| コンストラクタ | 説明 |
|---|---|
StreamSender(I2PSocket s,
int id) |
| 修飾子とタイプ | メソッド | 説明 |
|---|---|---|
abstract void |
run() |
|
abstract void |
sendBytes(java.io.InputStream in,
int size) |
Send bytes through the SAM STREAM session socket sender
|
abstract void |
shutDownGracefully() |
Stop a SAM STREAM session socket sender gracefully: stop the
sender thread once all pending data has been sent.
|
abstract void |
stopRunning() |
Stop a SAM STREAM session socket sender thread immediately
|
protected final int _id
protected final I2PSocket i2pSocket
public StreamSender(I2PSocket s, int id) throws java.io.IOException
java.io.IOExceptionpublic abstract void sendBytes(java.io.InputStream in,
int size)
throws java.io.IOException
in - Data input streamsize - Count of bytes to sendjava.io.IOException - if the client didnt provide enough datapublic abstract void stopRunning()
public abstract void shutDownGracefully()
public abstract void run()
run インタフェース内 java.lang.Runnable