ch.ethz.mxquery.sms.MMimpl
Class StreamStoreInput

java.lang.Object
  ch.ethz.mxquery.sms.MMimpl.StreamStoreInput

public class StreamStoreInput
extends java.lang.Object

Constructor Summary

StreamStoreInput(StreamStore target)
Create a new stream store input that will stop consuming if the input

StreamStoreInput(StreamStore target, boolean ignoreItemEnds)
Create a new stream store input.

Method Summary

boolean	bufferNext(Token token) Place the token into the stream store, automatically determining the item boundaries
void	endStream()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamStoreInput

public StreamStoreInput(StreamStore target)

Create a new stream store input that will stop consuming if the input

Parameters:

target - the stream store that consumes the input

StreamStoreInput

public StreamStoreInput(StreamStore target,
                        boolean ignoreItemEnds)

Create a new stream store input. The end of sequence of an input will be ignored, so that a stream of multiple items can be combined

Parameters:

target - the stream store that consumes the input

ignoreItemEnds - if true, end of sequence tokens are discarded

Method Detail

endStream

public void endStream()
               throws MXQueryException

Throws:

MXQueryException

bufferNext

public boolean bufferNext(Token token)
                   throws MXQueryException

Place the token into the stream store, automatically determining the item boundaries

Parameters:

token - an XDM token

Returns:

true if the end of of the input sequence has been reached

Throws:

MXQueryException