Package org.dellroad.msrp.msg

Class MsrpInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

org.dellroad.msrp.msg.MsrpInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class MsrpInputStream
extends FilterInputStream

Wraps an InputStream and parses MSRP messages from the underlying input.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
MsrpInputStream(InputStream input)	Constructor.
MsrpInputStream(InputStream input, MsrpInputParser parser)	Primary constructor.

Method Summary

Modifier and Type	Method	Description
MsrpInputParser	getParser()	Get the MsrpInputParser associated with this instance.
MsrpMessage	readMsrpMessage()	Read the next MsrpMessage from the underlying input stream.

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Detail

MsrpInputStream

public MsrpInputStream(InputStream input)

Constructor. Uses a MsrpInputParser with default parameters.

Parameters:

input - underlying input

Throws:

IllegalArgumentException - if input is null

MsrpInputStream

public MsrpInputStream(InputStream input,
                       MsrpInputParser parser)

Primary constructor.

Parameters:

input - underlying input

parser - parser

Throws:

IllegalArgumentException - if either parameter is null

Method Detail

getParser

public MsrpInputParser getParser()

Get the MsrpInputParser associated with this instance.

Returns:

associated parser

readMsrpMessage

public MsrpMessage readMsrpMessage()
                            throws IOException

Read the next MsrpMessage from the underlying input stream.

Returns:

next message read, or null if EOF is detected

Throws:

IOException - if an I/O error occurs

ProtocolException - if a protocol violation is detected

EOFException - if the remote side has closed the connection in the middle of a message