Sink
, Source
, EventDispatcher
SOCKSUDPTunnel
, StreamrConsumer
public abstract class I2PTunnelUDPClientBase extends I2PTunnelTask implements Source, Sink
修飾子とタイプ | フィールド | 説明 |
---|---|---|
protected long |
_clientId |
|
protected I2PAppContext |
_context |
|
(package private) static long |
DEFAULT_CONNECT_TIMEOUT |
|
protected Logging |
l |
open
コンストラクタ | 説明 |
---|---|
I2PTunnelUDPClientBase(java.lang.String destination,
Logging l,
EventDispatcher notifyThis,
I2PTunnel tunnel) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
boolean |
close(boolean forced) |
I2PTunnelTask Methods
Classes should override to close UDP side as well
|
void |
send(Destination to,
byte[] data) |
Sink Methods
|
void |
setSink(Sink s) |
Source Methods
Sets the receiver of the UDP datagrams from I2P
Subclass must call this after constructor
and before start()
|
void |
start() |
start the source
|
void |
startRunning() |
Actually start working on outgoing connections.
|
attachEventDispatcher, detachEventDispatcher, getEventDispatcher, getEvents, getEventValue, ignoreEvents, notifyEvent, unIgnoreEvents, waitEventValue
connected, destroy, disconnected, errorOccurred, getId, getTunnel, isOpen, optionsUpdated, reportAbuse, routerDisconnected, setId, setName, setTunnel, toString
protected I2PAppContext _context
protected Logging l
static final long DEFAULT_CONNECT_TIMEOUT
protected long _clientId
public I2PTunnelUDPClientBase(java.lang.String destination, Logging l, EventDispatcher notifyThis, I2PTunnel tunnel) throws java.lang.IllegalArgumentException
java.lang.IllegalArgumentException
- if the I2CP configuration is b0rked so
badly that we cant create a socketManagerpublic void startRunning()
public boolean close(boolean forced)
close
クラス内 I2PTunnelTask
public void setSink(Sink s)
public void send(Destination to, byte[] data)