public class ForkAdjunct extends StreamingAdjunct
The general strategy is to create an inversion of the expression in each prong of the fork, and to create a separate watch for each one. These watches create output which is buffered, and on completion the outputs of each watch are assembled in the right order.
The implementation is NOT multithreaded: although the prongs of the fork execute conceptually in parallel, in that they all act as listeners responding to the same sequence of events, they actually all run in the same thread.
|Constructor and Description|
|Modifier and Type||Method and Description|
Compute the posture and sweep of this expression as defined in the W3C streamability specifications.
Get a WatchMaker, a factory class that creates a Watch to evaluate this expression in streaming mode.
emptyAdjunctMap, findConsumingArg, getConfiguration, getDefaultFeedMaker, getExpression, getFeedMaker, makeStreamingAdjunct, setConfiguration, setExpression, toStreamingPattern
public PostureAndSweep computeStreamability(ContextItemStaticInfoEE contextInfo, java.util.List<java.lang.String> reasons)
public WatchMaker getWatchMaker(boolean forGrouping) throws XPathException
Copyright (c) 2004-2022 Saxonica Limited. All rights reserved.