Juan Rodriguez Hortala

Note the [event reordering capabilities of Flink](http://data-artisans.com/how-apache-flink-enables-new-streaming-applications-part-1/) could maybe be exploited for defining reliable synthetic stream generators

add license to all sources

The Vector of DStreams cannot be replaced by a TheadLocal variable because the driver thread needs to access each of the DStreams in the vector

If we are already specifying the number of workers outside the prop, we could think of that not as a number of workers but as number of multiplexed test cases,...

Note ScalaCheck is not a problem here, because when it gets a undecided result for a test case it continues with the next test case. This can we tested by...

currently converting `Prop.Undecided` into `Prop.passed` as we are interested in finding counterexamples, this should be the default but also should be configurable

see check() at https://github.com/rickynils/scalacheck/blob/1.12.2/src/main/scala/org/scalacheck/Test.scala, in particular ``` scala import concurrent._ val tp = java.util.concurrent.Executors.newFixedThreadPool(workers) implicit val ec = ExecutionContext.fromExecutor(tp) try { val fs = List.range(0,workers) map (idx => Future {...

Now using `par` in `consume` method of `NextAnd` and `NextOr`, this improved performance dramatically. Note `consume` is invoked in `DStreamProp.forAll` at a `foreachRDD`, thus in the driver. That could imply...

see http://mail-archives.us.apache.org/mod_mbox/spark-user/201403.mbox/%3CCAMwrk0=ZNRFuPGfpD+mdyHX3wM8fEODtNTYY3EmjH2B2c2GuuA@mail.gmail.com%3E "[...]However dynamically changing the computation can be done using DStream.transform() or DStream.foreachRDD() Both these operations allow you to do arbitrary RDD operations on each RDD. So you can...

for now this only applies to the branch quantifiers_experiments