for now support only 1 input dstream and 1 derived dstream
create derived dstreams from the generated dstream, and assert on them, abstracting away from
test multiplexion: try with a derived dstream for map(_+1) and adapt the assertions
add some test examples: use TL generators for that?: don't forget test that ensures that batches are not mixed, following the one in the PoC for #6