Package net.schmizz.sshj.common

Class StreamCopier

java.lang.Object

net.schmizz.sshj.common.StreamCopier

public class StreamCopier
extends java.lang.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 java.io.InputStream	in
private boolean	keepFlushing
private long	length
private StreamCopier.Listener	listener
private org.slf4j.Logger	log
private LoggerFactory	loggerFactory
private static StreamCopier.Listener	NULL_LISTENER
private java.io.OutputStream	out

Constructor Summary

Constructors

Constructor	Description
StreamCopier(java.io.InputStream in, java.io.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<java.io.IOException>	spawn(java.lang.String name)
private Event<java.io.IOException>	spawn(java.lang.String name, boolean daemon)
Event<java.io.IOException>	spawnDaemon(java.lang.String name)
private long	write(byte[] buf, long curPos, int len)

Methods inherited from class java.lang.Object

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

Field Detail

NULL_LISTENER

private static final StreamCopier.Listener NULL_LISTENER

loggerFactory

private final LoggerFactory loggerFactory

log

private final org.slf4j.Logger log

in

private final java.io.InputStream in

out

private final java.io.OutputStream out

listener

private StreamCopier.Listener listener

bufSize

private int bufSize

keepFlushing

private boolean keepFlushing

length

private long length

Constructor Detail

StreamCopier

public StreamCopier(java.io.InputStream in,
                    java.io.OutputStream out,
                    LoggerFactory loggerFactory)

Method Detail

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<java.io.IOException> spawn(java.lang.String name)

spawnDaemon

public Event<java.io.IOException> spawnDaemon(java.lang.String name)

spawn

private Event<java.io.IOException> spawn(java.lang.String name,
                                         boolean daemon)

copy

public long copy()
          throws java.io.IOException

Throws:

java.io.IOException

write

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

Throws:

java.io.IOException