java.lang.Runnable
protected 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.IOException
public 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