Add delete-by stream primitive and test case
Merge branch 'delete-by' into production