## net.i2p.i2ptunnel.streamr
Class StreamrConsumer

    java.lang.Object
      net.i2p.i2ptunnel.I2PTunnelTask
          net.i2p.i2ptunnel.udpTunnel.I2PTunnelUDPClientBase
              net.i2p.i2ptunnel.streamr.StreamrConsumer

All Implemented Interfaces:
  Sink, Source, EventDispatcher

    public class StreamrConsumer

extends I2PTunnelUDPClientBase

Compared to a standard I2PTunnel, this acts like a client on the I2P side (no privkey file) but a server on the UDP side (sends to a configured host/port)

Author:
  welterde, zzz modded for I2PTunnel

Field Summary

Fields inherited from class net.i2p.i2ptunnel.udpTunnel.I2PTunnelUDPClientBase
`_clientId, _context, dest, l`

Fields inherited from class net.i2p.i2ptunnel.I2PTunnelTask
`open`

Constructor Summary
`StreamrConsumer(InetAddress host, int port, String destination, Logging l, EventDispatcher notifyThis, I2PTunnel tunnel)`

Method Summary
`boolean` `close(boolean forced)` I2PTunnelTask Methods Classes should override to close UDP side as well
`void` `startRunning()` Actually start working on outgoing connections.

Methods inherited from class net.i2p.i2ptunnel.udpTunnel.I2PTunnelUDPClientBase
`send, setSink, start`

Methods inherited from class net.i2p.i2ptunnel.I2PTunnelTask
`attachEventDispatcher, detachEventDispatcher, disconnected, errorOccurred, getEventDispatcher, getEvents, getEventValue, getId, getTunnel, ignoreEvents, isOpen, notifyEvent, reportAbuse, routerDisconnected, setId, setName, setTunnel, toString, unIgnoreEvents, waitEventValue`

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait`

Constructor Detail

### StreamrConsumer

    public StreamrConsumer(InetAddress host,
                           int port,
                           String destination,
                           Logging l,
                           EventDispatcher notifyThis,
                           I2PTunnel tunnel)

Method Detail

### startRunning

    public final void startRunning()

  Description copied from class: `I2PTunnelUDPClientBase`
  Actually start working on outgoing connections. Classes should override to start UDP side as well. Not specified in I2PTunnelTask but used in both I2PTunnelClientBase and I2PTunnelServer so let's implement it here too.

  Overrides:
    `startRunning` in class `I2PTunnelUDPClientBase`

### close

    public boolean close(boolean forced)

  Description copied from class: `I2PTunnelUDPClientBase`
  I2PTunnelTask Methods Classes should override to close UDP side as well

  Overrides:
    `close` in class `I2PTunnelUDPClientBase`