Class StreamCopier

java.lang.Object

net.schmizz.sshj.common.StreamCopier

public class StreamCopier
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StreamCopier.Listener

Field Summary

Fields

Modifier and Type	Field	Description
private int	bufSize
private final InputStream	in
private boolean	keepFlushing
private long	length
private StreamCopier.Listener	listener
private final org.slf4j.Logger	log
private final LoggerFactory	loggerFactory
private static final StreamCopier.Listener	NULL_LISTENER
private final OutputStream	out

Constructor Summary

Constructors

Constructor	Description
StreamCopier(InputStream in, OutputStream out, LoggerFactory loggerFactory)

Method Summary

Modifier and Type	Method	Description
StreamCopier	bufSize(int bufSize)
long	copy()
StreamCopier	keepFlushing(boolean keepFlushing)
StreamCopier	length(long length)
StreamCopier	listener(StreamCopier.Listener listener)
Event<IOException>	spawn(String name)
private Event<IOException>	spawn(String name, boolean daemon)
Event<IOException>	spawnDaemon(String name)
private long	write(byte[] buf, long curPos, int len)

Methods inherited from class Object

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

Field Details

NULL_LISTENER

private static final StreamCopier.Listener NULL_LISTENER

loggerFactory

private final LoggerFactory loggerFactory

log

private final org.slf4j.Logger log

in

private final InputStream in

out

private final OutputStream out

listener

private StreamCopier.Listener listener

bufSize

private int bufSize

keepFlushing

private boolean keepFlushing

length

private long length

Constructor Details

StreamCopier

public StreamCopier(InputStream in,
 OutputStream out,
 LoggerFactory loggerFactory)

Method Details

bufSize

public StreamCopier bufSize(int bufSize)

keepFlushing

public StreamCopier keepFlushing(boolean keepFlushing)

listener

public StreamCopier listener(StreamCopier.Listener listener)

length

public StreamCopier length(long length)

spawn

public Event<IOException> spawn(String name)

spawnDaemon

public Event<IOException> spawnDaemon(String name)

spawn

private Event<IOException> spawn(String name,
 boolean daemon)

copy

public long copy()
          throws IOException

Throws:

IOException

write

private long write(byte[] buf,
 long curPos,
 int len)
            throws IOException

Throws:

IOException