org.apache.ftpserver.util
Class StreamConnector

java.lang.Object
  extended by org.apache.ftpserver.util.StreamConnector
All Implemented Interfaces:
Runnable

public class StreamConnector
extends Object
implements Runnable

Connect one java.io.InputStream with a java.io.OutputStream. Features:

Author:
Rana Bhattacharyya

Constructor Summary
StreamConnector(InputStream in, OutputStream out)
          Constructors
 
Method Summary
 void connect()
          Connect two streams.
protected  void finalize()
          Last defense to stop thread.
 Exception getException()
          Get exception.
 boolean getIsBuffered()
          Get is buffered.
 boolean getIsThreaded()
          Is the data transfer threaded?
 int getMaxTransferRate()
          Get transfer limit in bytes/second.
 long getTransferredSize()
          Get transferred size in bytes.
 boolean hasException()
          Check exception status.
 boolean isStopped()
          Is stopped?
 void run()
          Transfer data from one stream to another.
 void setIsBuffered(boolean buf)
          Set buffered transferred property.
 void setIsThreaded(boolean thr)
          Set threaded transfer property.
 void setMaxTransferRate(int limit)
          Set transfer limit - bytes/second.
 void setObserver(StreamConnectorObserver obsr)
          Set stream connector observer.
 void stopTransfer()
          Stop data transfer.
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StreamConnector

public StreamConnector(InputStream in,
                       OutputStream out)
Constructors

Parameters:
in - pipe input
out - pipe output
Method Detail

setObserver

public void setObserver(StreamConnectorObserver obsr)
Set stream connector observer.


setIsBuffered

public void setIsBuffered(boolean buf)
Set buffered transferred property.


getIsBuffered

public boolean getIsBuffered()
Get is buffered.


setIsThreaded

public void setIsThreaded(boolean thr)
Set threaded transfer property.


getIsThreaded

public boolean getIsThreaded()
Is the data transfer threaded?


getException

public Exception getException()
Get exception.


getTransferredSize

public long getTransferredSize()
Get transferred size in bytes.


getMaxTransferRate

public int getMaxTransferRate()
Get transfer limit in bytes/second.


setMaxTransferRate

public void setMaxTransferRate(int limit)
Set transfer limit - bytes/second.


hasException

public boolean hasException()
Check exception status.


stopTransfer

public void stopTransfer()
Stop data transfer.


isStopped

public boolean isStopped()
Is stopped?


connect

public void connect()
Connect two streams.


run

public void run()
Transfer data from one stream to another.

Specified by:
run in interface Runnable

finalize

protected void finalize()
                 throws Throwable
Last defense to stop thread.

Overrides:
finalize in class Object
Throws:
Throwable


Copyright © 2001-2012 Codehaus. All Rights Reserved.