|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.apache.xml.dtm.ref.IncrementalSAXSource_Filter
IncrementalSAXSource_Filter implements IncrementalSAXSource, using a standard SAX2 event source as its input and parcelling out those events gradually in reponse to deliverMoreNodes() requests. Output from the filter will be passed along to a SAX handler registered as our listener, but those callbacks will pass through a counting stage which periodically yields control back to the controller coroutine.
%REVIEW%: This filter is not currenly intended to be reusable for parsing additional streams/documents. We may want to consider making it resettable at some point in the future. But it's a small object, so that'd be mostly a convenience issue; the cost of allocating each time is trivial compared to the cost of processing any nontrival stream.
For a brief usage example, see the unit-test main() method.
This is a simplification of the old CoroutineSAXParser, focusing specifically on filtering. The resulting controller protocol is _far_ simpler and less error-prone; the only controller operation is deliverMoreNodes(), and the only requirement is that deliverMoreNodes(false) be called if you want to discard the rest of the stream and the previous deliverMoreNodes() didn't return false.
Constructor Summary | |
IncrementalSAXSource_Filter()
|
|
IncrementalSAXSource_Filter(CoroutineManager co,
int controllerCoroutineID)
Create a IncrementalSAXSource_Filter which is not yet bound to a specific SAX event source. |
Method Summary | |
void |
characters(char[] ch,
int start,
int length)
|
void |
comment(char[] ch,
int start,
int length)
|
static IncrementalSAXSource |
createIncrementalSAXSource(CoroutineManager co,
int controllerCoroutineID)
|
java.lang.Object |
deliverMoreNodes(boolean parsemore)
deliverMoreNodes() is a simple API which tells the coroutine parser that we need more nodes. |
void |
endCDATA()
|
void |
endDocument()
|
void |
endDTD()
|
void |
endElement(java.lang.String namespaceURI,
java.lang.String localName,
java.lang.String qName)
|
void |
endEntity(java.lang.String name)
|
void |
endPrefixMapping(java.lang.String prefix)
|
void |
error(SAXParseException exception)
|
void |
fatalError(SAXParseException exception)
|
int |
getControllerCoroutineID()
|
CoroutineManager |
getCoroutineManager()
|
int |
getSourceCoroutineID()
|
void |
ignorableWhitespace(char[] ch,
int start,
int length)
|
void |
init(CoroutineManager co,
int controllerCoroutineID,
int sourceCoroutineID)
|
void |
notationDecl(java.lang.String a,
java.lang.String b,
java.lang.String c)
|
void |
processingInstruction(java.lang.String target,
java.lang.String data)
|
void |
run()
|
void |
setContentHandler(ContentHandler handler)
|
void |
setDocumentLocator(Locator locator)
|
void |
setDTDHandler(DTDHandler handler)
|
void |
setErrHandler(ErrorHandler handler)
|
void |
setLexicalHandler(LexicalHandler handler)
|
void |
setReturnFrequency(int events)
|
void |
setXMLReader(XMLReader eventsource)
Bind our input streams to an XMLReader. |
void |
skippedEntity(java.lang.String name)
|
void |
startCDATA()
|
void |
startDocument()
|
void |
startDTD(java.lang.String name,
java.lang.String publicId,
java.lang.String systemId)
|
void |
startElement(java.lang.String namespaceURI,
java.lang.String localName,
java.lang.String qName,
Attributes atts)
|
void |
startEntity(java.lang.String name)
|
void |
startParse(InputSource source)
Launch a thread that will run an XMLReader's parse() operation within a thread, feeding events to this IncrementalSAXSource_Filter. |
void |
startPrefixMapping(java.lang.String prefix,
java.lang.String uri)
|
void |
unparsedEntityDecl(java.lang.String a,
java.lang.String b,
java.lang.String c,
java.lang.String d)
|
void |
warning(SAXParseException exception)
|
Methods inherited from class java.lang.Object |
equals,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
Constructor Detail |
public IncrementalSAXSource_Filter()
public IncrementalSAXSource_Filter(CoroutineManager co, int controllerCoroutineID)
Method Detail |
public static IncrementalSAXSource createIncrementalSAXSource(CoroutineManager co, int controllerCoroutineID)
public void init(CoroutineManager co, int controllerCoroutineID, int sourceCoroutineID)
public void setXMLReader(XMLReader eventsource)
public void setContentHandler(ContentHandler handler)
public void setDTDHandler(DTDHandler handler)
public void setLexicalHandler(LexicalHandler handler)
public void setErrHandler(ErrorHandler handler)
public void setReturnFrequency(int events)
public void characters(char[] ch, int start, int length) throws SAXException
public void endDocument() throws SAXException
public void endElement(java.lang.String namespaceURI, java.lang.String localName, java.lang.String qName) throws SAXException
public void endPrefixMapping(java.lang.String prefix) throws SAXException
public void ignorableWhitespace(char[] ch, int start, int length) throws SAXException
public void processingInstruction(java.lang.String target, java.lang.String data) throws SAXException
public void setDocumentLocator(Locator locator)
public void skippedEntity(java.lang.String name) throws SAXException
public void startDocument() throws SAXException
public void startElement(java.lang.String namespaceURI, java.lang.String localName, java.lang.String qName, Attributes atts) throws SAXException
public void startPrefixMapping(java.lang.String prefix, java.lang.String uri) throws SAXException
public void comment(char[] ch, int start, int length) throws SAXException
public void endCDATA() throws SAXException
public void endDTD() throws SAXException
public void endEntity(java.lang.String name) throws SAXException
public void startCDATA() throws SAXException
public void startDTD(java.lang.String name, java.lang.String publicId, java.lang.String systemId) throws SAXException
public void startEntity(java.lang.String name) throws SAXException
public void notationDecl(java.lang.String a, java.lang.String b, java.lang.String c) throws SAXException
public void unparsedEntityDecl(java.lang.String a, java.lang.String b, java.lang.String c, java.lang.String d) throws SAXException
public void error(SAXParseException exception) throws SAXException
public void fatalError(SAXParseException exception) throws SAXException
public void warning(SAXParseException exception) throws SAXException
public int getSourceCoroutineID()
public int getControllerCoroutineID()
public CoroutineManager getCoroutineManager()
public void startParse(InputSource source) throws SAXException
public void run()
public java.lang.Object deliverMoreNodes(boolean parsemore)
parsemore
- If true, tells the incremental filter to generate
another chunk of output. If false, tells the filter that we're
satisfied and it can terminate parsing of this document.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |