Package de.aristaflow.adept2.model.common.communication

Class ServerInputStream

java.lang.Object

de.aristaflow.adept2.model.common.communication.ServerInputStream

All Implemented Interfaces:

ServerStream

Direct Known Subclasses:

ServerUDTInputStream

public class ServerInputStream
extends Object
implements ServerStream

This is a simple wrapper for an InputStream as ServerStream which allows for keeping an InputStream locally and use it remotely.

Author:

Ulrich Kreher

Constructor Summary

Constructors

Constructor	Description
ServerInputStream(InputStream in)	Creates a new ServerInputStream providing the content of the designated stream incrementally on client side.

Method Summary

Modifier and Type	Method	Description
int	available()	InputStream.available()
void	close()	InputStream.close() This additionally removes the skeleton in the communication framework.
void	mark(int readlimit)	InputStream.mark(int)
boolean	markSupported()	InputStream.markSupported()
int	read()	InputStream.read()
byte[]	read(int len)	Resembles InputStream.read(byte[]) by reading the designated amount of bytes from the stream.
void	reset()	InputStream.reset()
long	skip(long n)	InputStream.skip(long)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerInputStream

public ServerInputStream(InputStream in)

Creates a new ServerInputStream providing the content of the designated stream incrementally on client side. Note that this stream as well as the wrapped InputStream will be closed by the remote site. Therefore you should only close this stream (or the wrapped InputStream) if you are sure that the remote side has not closed it and will not close it, for instance since it disconnected abruptly.

Parameters:

in - The stream of which the content will be provided incrementally on client side. This stream will be closed by the remote side.

Method Detail

read

public int read()
         throws IOException

Description copied from interface: ServerStream

InputStream.read()

Specified by:

read in interface ServerStream

Throws:

IOException

read

public byte[] read(int len)
            throws IOException

Description copied from interface: ServerStream

Resembles InputStream.read(byte[]) by reading the designated amount of bytes from the stream. If there are less bytes remaining in the stream, the returned byte array will be correspondingly shorter. If no bytes remain (java.io.InputStream#read(byte[]) returns -1), null will be returned.

Specified by:

read in interface ServerStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Description copied from interface: ServerStream

InputStream.skip(long)

Specified by:

skip in interface ServerStream

Throws:

IOException

available

public int available()
              throws IOException

Description copied from interface: ServerStream

InputStream.available()

Specified by:

available in interface ServerStream

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: ServerStream

InputStream.close() This additionally removes the skeleton in the communication framework.

Specified by:

close in interface ServerStream

Throws:

IOException

mark

public void mark(int readlimit)

Description copied from interface: ServerStream

InputStream.mark(int)

Specified by:

mark in interface ServerStream

reset

public void reset()
           throws IOException

Description copied from interface: ServerStream

InputStream.reset()

Specified by:

reset in interface ServerStream

Throws:

IOException

markSupported

public boolean markSupported()

Description copied from interface: ServerStream

InputStream.markSupported()

Specified by:

markSupported in interface ServerStream