do you mean something like "inject" function 
<http://groovy.codehaus.org/groovy-jdk/java/util/Collection.html#inject(U, 
groovy.lang.Closure)>in Groovy which is sending the result of one call to 
the another or more like following "cumulate" method?

// some starter code
while(cursor.hasNext){
  Pipes.cumulate(NextNode.class, cursor.next());
}


// next node class
NodeResult execute(ParallelPipe pipe, Entity en){
  // count something based on the entity
  pipe.join(TheFinalNode.class, count);
}

// the final node class
NodeResult execute(SerialPipe pipe, Collection<Long>){
 // do something with the counts
}





-- 
You received this message because you are subscribed to the Google Groups 
"Google App Engine" group.
To view this discussion on the web visit 
https://groups.google.com/d/msg/google-appengine/-/DleFGCOSDQ8J.
To post to this group, send email to [email protected].
To unsubscribe from this group, send email to 
[email protected].
For more options, visit this group at 
http://groups.google.com/group/google-appengine?hl=en.

Reply via email to