Class SftpInputStreamWithChannel
- java.lang.Object
-
- java.io.InputStream
-
- org.apache.sshd.common.util.io.InputStreamWithChannel
-
- org.apache.sshd.client.subsystem.sftp.SftpInputStreamWithChannel
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,java.nio.channels.Channel
public class SftpInputStreamWithChannel extends InputStreamWithChannel
Implements an input stream for reading from a remote file
-
-
Field Summary
Fields Modifier and Type Field Description private int
available
private byte[]
bb
private byte[]
buffer
private SftpClient
client
private SftpClient.CloseableHandle
handle
private int
index
private long
offset
private java.lang.String
path
-
Constructor Summary
Constructors Constructor Description SftpInputStreamWithChannel(SftpClient client, int bufferSize, java.lang.String path, java.util.Collection<SftpClient.OpenMode> mode)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
SftpClient
getClient()
The client instancejava.lang.String
getPath()
The remotely accessed file pathboolean
isOpen()
void
mark(int readlimit)
boolean
markSupported()
int
read()
int
read(byte[] b, int off, int len)
void
reset()
long
skip(long n)
-
-
-
Field Detail
-
client
private final SftpClient client
-
path
private final java.lang.String path
-
bb
private byte[] bb
-
buffer
private byte[] buffer
-
index
private int index
-
available
private int available
-
handle
private SftpClient.CloseableHandle handle
-
offset
private long offset
-
-
Constructor Detail
-
SftpInputStreamWithChannel
public SftpInputStreamWithChannel(SftpClient client, int bufferSize, java.lang.String path, java.util.Collection<SftpClient.OpenMode> mode) throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
getClient
public final SftpClient getClient()
The client instance- Returns:
SftpClient
instance used to access the remote file
-
getPath
public final java.lang.String getPath()
The remotely accessed file path- Returns:
- Remote file path
-
isOpen
public boolean isOpen()
-
markSupported
public boolean markSupported()
- Overrides:
markSupported
in classjava.io.InputStream
-
mark
public void mark(int readlimit)
- Overrides:
mark
in classjava.io.InputStream
-
skip
public long skip(long n) throws java.io.IOException
- Overrides:
skip
in classjava.io.InputStream
- Throws:
java.io.IOException
-
reset
public void reset() throws java.io.IOException
- Overrides:
reset
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read() throws java.io.IOException
- Specified by:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b, int off, int len) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.nio.channels.Channel
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classjava.io.InputStream
- Throws:
java.io.IOException
-
-