co.cask.cdap.runtime.spi.ssh

Class PortForwarding.DataConsumer

java.lang.Object

co.cask.cdap.runtime.spi.ssh.PortForwarding.DataConsumer

Enclosing interface:

PortForwarding

public abstract static class PortForwarding.DataConsumer
extends Object

This class is for consuming incoming data from the SSH port forwarding channel.

Constructor Summary

Constructors

Constructor and Description
DataConsumer()

Method Summary

Modifier and Type	Method and Description
void	finished() Invoked when the channel is closed and no more data will be received.
void	flushed() Invoked when there is a flush event received from the channel.
abstract void	received(ByteBuffer buffer) Invoked when new data is received.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataConsumer

public DataConsumer()

Method Detail

received

public abstract void received(ByteBuffer buffer)

Invoked when new data is received.

Parameters:

buffer - the content of the data received

flushed

public void flushed()

Invoked when there is a flush event received from the channel.

finished

public void finished()

Invoked when the channel is closed and no more data will be received.