Package net.schmizz.sshj.connection.channel

Class ChannelInputStream

java.lang.Object

java.io.InputStream

net.schmizz.sshj.connection.channel.ChannelInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, ErrorNotifiable

public final class ChannelInputStream
extends InputStream
implements ErrorNotifiable

InputStream for channels. Can receive data into its buffer for serving to readers.

Nested Class Summary

Nested classes/interfaces inherited from interface net.schmizz.sshj.common.ErrorNotifiable

ErrorNotifiable.Util

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	b
private final CircularBuffer.PlainCircularBuffer	buf
private final Channel	chan
private boolean	eof
private SSHException	error
private final org.slf4j.Logger	log
private final Transport	trans
private final Window.Local	win

Constructor Summary

Constructors

Constructor	Description
ChannelInputStream(Channel chan, Transport trans, Window.Local win)

Method Summary

Modifier and Type	Method	Description
int	available()
private void	checkWindow()
void	close()
void	eof()
void	notifyError(SSHException error)	Notifies this object of an error.
int	read()
int	read(byte[] b, int off, int len)
void	receive(byte[] data, int offset, int len)
String	toString()

Methods inherited from class java.io.InputStream

mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Field Details

log

private final org.slf4j.Logger log

chan

private final Channel chan

trans

private final Transport trans

win

private final Window.Local win

buf

private final CircularBuffer.PlainCircularBuffer buf

b

private final byte[] b

eof

private boolean eof

error

private SSHException error

Constructor Details

ChannelInputStream

public ChannelInputStream(Channel chan,
 Transport trans,
 Window.Local win)

Method Details

available

public int available()

Overrides:

available in class InputStream

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

eof

public void eof()

notifyError

public void notifyError(SSHException error)

Description copied from interface: ErrorNotifiable

Notifies this object of an error.

Specified by:

notifyError in interface ErrorNotifiable

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

receive

public void receive(byte[] data,
 int offset,
 int len)
             throws SSHException

Throws:

SSHException

checkWindow

private void checkWindow()
                  throws TransportException

Throws:

TransportException

toString

public String toString()

Overrides:

toString in class Object