Also this is not so much "lambda queries". It is stream-based querying.