diff --git a/contracts/okp4-cognitarium/src/querier/engine.rs b/contracts/okp4-cognitarium/src/querier/engine.rs index 9c1b827e..8c160316 100644 --- a/contracts/okp4-cognitarium/src/querier/engine.rs +++ b/contracts/okp4-cognitarium/src/querier/engine.rs @@ -34,7 +34,12 @@ impl<'a> QueryEngine<'a> { Box::new(move |_| Box::new(iter::empty())) } QueryNode::ForLoopJoin { left, right } => Box::new(move |_| Box::new(iter::empty())), - QueryNode::Skip { child, first } => Box::new(move |_| Box::new(iter::empty())), + QueryNode::Skip { child, first } => { + let upstream = self.eval_node(child); + Box::new(move |vars| -> ResolvedVariablesIterator { + Box::new(upstream(vars).skip(first)) + }) + } QueryNode::Limit { child, first } => { let upstream = self.eval_node(child); Box::new(move |vars| -> ResolvedVariablesIterator {