trait _trigger[A] extends AnyRef
Ordering
- Alphabetic
Inherited
- Stream._extend._trigger
- scala.AnyRef
- scala.Any
- Hide All
- Show All
Visibility
- Public
- All
Method
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
triggerEmpty(f: ⇒ Unit): ~[A]
Run for empty
-
def
triggerEvery(seconds: Double, f: (Int, Double) ⇒ Unit): ~[A]
Run on timer
Run on timer
Runs given function every specified time period in fractional seconds, while elements are being pumped
Note, it will not run even once if all elements pumped in less than the given seconds
- seconds
period to run
- f
function with cumulative element count and cumulative time in seconds as arguments
- Definition Classes
- _trigger
-
def
triggerFirst(f: ⇒ Any): ~[A]
Runs before first
Runs before first
Runs given statement when the first element pumped, but before it is passed down the pipeline
This will not run for empty pipeline
- Definition Classes
- _trigger
-
def
triggerLast(f: (Int, Double) ⇒ Unit): ~[A]
Runs after last
Runs after last
Runs given function when pumping for the next element brings nothing
This will not run for empty pipeline
- f
Function with element count and time in seconds it took to pump all elements
- Definition Classes
- _trigger
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Trigger Interface
Allows to provide status of ongoing processing