Field Detail

• _id

  protected final int _id

  _id.

• i2pSocket

  protected final I2PSocket i2pSocket

  i2pSocket.

Constructor Detail

• StreamSender

  public StreamSender(I2PSocket s,
                      int id)
               throws IOException

  Create a new StreamSender.

  Parameters:

  s - the I2PSocket to write to

  id - the stream id

  Throws:

  IOException - if the output stream cannot be obtained

Method Detail

• run

  public abstract void run()

  run().

  Specified by:

  run in interface Runnable

• sendBytes

  public abstract void sendBytes(InputStream in,
                                 int size)
                          throws IOException

  Send bytes through the SAM STREAM session socket sender

  Parameters:

  in - Data input stream

  size - Count of bytes to send

  Throws:

  IOException - if the client didnt provide enough data

• shutDownGracefully

  public abstract void shutDownGracefully()

  Stop a SAM STREAM session socket sender gracefully: stop the sender thread once all pending data has been sent.

• stopRunning

  public abstract void stopRunning()

  Stop a SAM STREAM session socket sender thread immediately