SSHJ's SFTPFileTransfer

SFTPFileTransfer.java

private LocalDestFile downloadFile(final StreamCopier.Listener listener,
                                   final RemoteResourceInfo remote,
                                   final LocalDestFile local)
        throws IOException {
    final LocalDestFile adjusted = local.getTargetFile(remote.getName());
    final RemoteFile rf = engine.open(remote.getPath());
    try {
        final RemoteFile.ReadAheadRemoteFileInputStream rfis = rf.new ReadAheadRemoteFileInputStream(16);
        final OutputStream os = adjusted.getOutputStream();
        try {
            new StreamCopier(rfis, os, engine.getLoggerFactory())
                    .bufSize(engine.getSubsystem().getLocalMaxPacketSize())
                    .keepFlushing(false)
                    .listener(listener)
                    .copy();
        } finally {
            rfis.close();
            os.close();
        }
    } finally {
        rf.close();
    }
    return adjusted;
}