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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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
-
-