org.xbup.io.stream

Class XBTInputStream

java.lang.Object

org.xbup.io.stream.XBTInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, XBTEventProvider

Direct Known Subclasses:

XBTCPRemoteServer.XBL1PullInputStream, XBTFileInputStream, XBTFilterInputStream, XBTInputStream.XBTEventIStream, XBTInputStreamFilter, XBToXBTStreamConvertor, XBToXBTStreamUndropConvertor

public abstract class XBTInputStream
extends java.lang.Object
implements java.io.Closeable, XBTEventProvider

Standard input stream for XBUP Level 1 items.

Version:

0.1 wr19.0 2010/05/30

Author:

XBUP Project (http://xbup.org)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	XBTInputStream.XBTEventIStream

Constructor Summary

Constructors

Constructor and Description
XBTInputStream()

Method Summary

Methods

Modifier and Type	Method and Description
void	attachXBTEventListener(XBTEventListener eventListener) Attach event listener.
int	available()
void	close() Close source and release locks
abstract XBTToken	getXBT() Get next item in stream
static XBTInputStream	getXBTEventStream(XBTEventProvider provider)
void	reset() Reset Source
void	skip() Skip single block
void	toXBTEvents() Process stream as stream of events

Methods inherited from class java.lang.Object

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

Constructor Detail

XBTInputStream

public XBTInputStream()

Method Detail

getXBTEventStream

public static XBTInputStream getXBTEventStream(XBTEventProvider provider)

attachXBTEventListener

public void attachXBTEventListener(XBTEventListener eventListener)

Attach event listener. Can be attached only once

Specified by:

attachXBTEventListener in interface XBTEventProvider

toXBTEvents

public void toXBTEvents()
                 throws java.io.IOException,
                        XBProcessingException

Process stream as stream of events

Throws:

java.io.IOException

XBProcessingException

getXBT

public abstract XBTToken getXBT()
                         throws XBProcessingException

Get next item in stream

Returns:

PullItem object

Throws:

XBProcessingException

reset

public void reset()
           throws java.io.IOException

Reset Source

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Close source and release locks

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

skip

public void skip()
          throws XBProcessingException

Skip single block

Throws:

XBProcessingException

available

public int available()
              throws java.io.IOException

Throws:

java.io.IOException