Method execute

src/QLPlan.actor.cpp:309–314

}

FutureStream<Reference<ScanReturnedContext>> FilterPlan::execute(PlanCheckpoint* checkpoint,
                                                                 Reference<DocTransaction> tr) {
	PromiseStream<Reference<ScanReturnedContext>> output;
	checkpoint->addOperation(doFilter(checkpoint, source->execute(checkpoint, tr), output, filter), output);
	return output.getFuture();
}

ACTOR static Future<Void> toDocInfo(PlanCheckpoint* checkpoint,
                                    Reference<IReadWriteContext> base,