org.xbup.lib.core.remote

Class XBTCPRemoteServer.XBTPullInputStream

java.lang.Object

org.xbup.lib.core.stream.XBTInputTokenStream

org.xbup.lib.core.remote.XBTCPRemoteServer.XBTPullInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, XBTPullProvider

Enclosing class:

XBTCPRemoteServer

public class XBTCPRemoteServer.XBTPullInputStream
extends XBTInputTokenStream

Constructor Summary

Constructors

Constructor and Description
XBTPullInputStream(XBTPullProvider producer)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	finished() Returns true if stream ended.
XBTToken	pullXBTToken() Pull next token.
void	reset() Resets source - jump to beginning of stream.
void	skip(long tokenCount) Skip given count of tokens in stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

XBTPullInputStream

public XBTPullInputStream(XBTPullProvider producer)

Method Detail

pullXBTToken

public XBTToken pullXBTToken()
                      throws XBProcessingException

Description copied from interface: XBTPullProvider

Pull next token.

Returns:

next token

Throws:

XBProcessingException

reset

public void reset()
           throws java.io.IOException

Description copied from class: XBTInputTokenStream

Resets source - jump to beginning of stream.

Specified by:

reset in class XBTInputTokenStream

Throws:

java.io.IOException - if not possible to reset

finished

public boolean finished()
                 throws java.io.IOException

Description copied from class: XBTInputTokenStream

Returns true if stream ended.

Specified by:

finished in class XBTInputTokenStream

Returns:

true if stream ended

Throws:

java.io.IOException - if unable to determine stream end

skip

public void skip(long tokenCount)
          throws XBProcessingException,
                 java.io.IOException

Description copied from class: XBTInputTokenStream

Skip given count of tokens in stream.

Specified by:

skip in class XBTInputTokenStream

Parameters:

tokenCount - count of tokens

Throws:

java.io.IOException

XBProcessingException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException