object PStreamGen
All the temporal generators defined in this object are sized generators, but the size parameters only affects the number of batches in the output PDStream, not the size of the batches. The size of the batches can be changed by using Gen.resize in the definition of the batch generator that is passed to these HO generators
On the other hand for generators of arbitrary PDStreams like Gen.resize(5, arbitrary[DStream[Int]]) Gen.resize has effect, both in the number of batches and in the size of the batches, as those arbitrary instances are based on arbitrary for lists
TODO That should be tested // by using Gen.resize(5, TLGen.always(Batch(List(0, 1)))) (constant batch size) // and then in Gen.resize(3, TLGen.always(BatchGen.ofNtoM(1, 5, Gen.choose(0, 3)))) // the point is that we always have 3 batches, but Gen.resize doesn't affect the batch // size but only the number of batches //
- Alphabetic
- By Inheritance
- PStreamGen
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def always[A](dsg: Gen[PStream[A]], t: Timeout): Gen[PStream[A]]
- def always[A](dsg: Gen[PStream[A]]): Gen[PStream[A]]
Sized generator where the size acts like the timeout, so
Sized generator where the size acts like the timeout, so
- with size <= 0 returns the empty PDStream
- otherwise dsg happens size times from now
- def apply[A](dsg: Gen[PStream[A]]): PStreamGen[A]
- implicit def arbDStream[A](implicit arbBatch: Arbitrary[Window[A]]): Arbitrary[PStream[A]]
Arbitrary generator for DStream.
Arbitrary generator for DStream. Only works if an Arbitrary for Batch is also present. Note this hasn't been automatically derived from Buildables.buildableDStreamFromBatch for the same reason Gen.buildableOf has to be used with DStream instead of Gen.containerOf
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def dstreamUnion[A](gs1: Gen[PStream[A]], gs2: Gen[PStream[A]]): Gen[PStream[A]]
- returns
a generator for the batch-by-batch concatenation of the PDStreams generated by gs1 and gs2. Note we fill either PDStreams with empty batches This implies PDStreams are implicitly treated as they where infinitely extended with empty batches
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def eventually[A](dsg: Gen[PStream[A]], t: Timeout): Gen[PStream[A]]
- def eventually[A](dsg: Gen[PStream[A]]): Gen[PStream[A]]
Sized generator where the size acts like the timeout, so
Sized generator where the size acts like the timeout, so
- with size <= 0 returns the empty PDStream
- otherwise dsg happens at some moment between 0 and size instants
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def laterN[A](n: Int, dsg: Gen[PStream[A]]): Gen[PStream[A]]
- returns
a dstream generator that has n empty batches followed by the batches from dsg
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def next[A](dsg: Gen[PStream[A]]): Gen[PStream[A]]
- returns
a dstream generator that has an empty batch followed by the batches from dsg
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def of[T](bg: => Gen[Window[T]]): Gen[PStream[T]]
- returns
a generator of DStream that generates its batches from bg
- def ofN[T](n: Int, bg: Gen[Window[T]]): Gen[PStream[T]]
- returns
a generator of DStream that generates its batches from bg
- def ofNtoM[T](n: Int, m: Int, bg: Gen[Window[T]]): Gen[PStream[T]]
- returns
a generator of DStream that generates its batches from bg
- def release[A](dsg1: Gen[PStream[A]], dsg2: Gen[PStream[A]], t: Timeout): Gen[PStream[A]]
- def release[A](dsg1: Gen[PStream[A]], dsg2: Gen[PStream[A]]): Gen[PStream[A]]
Generator for the weak version of LTL release operator: either dsg2 happens forever, or it happens until dsg1 happens, including the moment when dsg1 happens
Generator for the weak version of LTL release operator: either dsg2 happens forever, or it happens until dsg1 happens, including the moment when dsg1 happens
This is a sized generator where the size acts like the timeout, so
- with size <= 0 returns the empty PDStream
- otherwise, if dsg1 happens then it happens after between 0 and size-1 instants
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def until[A](dsg1: Gen[PStream[A]], dsg2: Gen[PStream[A]], t: Timeout): Gen[PStream[A]]
- def until[A](dsg1: Gen[PStream[A]], dsg2: Gen[PStream[A]]): Gen[PStream[A]]
This is sized generator where the size acts like the timeout, so - with size <= 0 returns the empty PDStream, as no word can succeed with a timeout of 0 - with size 1 returns a PDStream generated by dsg2 - otherwise dsg2 happens after between 0 and size-1 instants
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)