c

com.avsystem.commons.jiop

ScalaJStream

final class ScalaJStream[+A] extends AnyVal

Linear Supertypes
AnyVal, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ScalaJStream
  2. AnyVal
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ScalaJStream(jStream: commons.JStream[A])

Value Members

  1. def allMatch(predicate: (A) ⇒ Boolean): Boolean
  2. def anyMatch(predicate: (A) ⇒ Boolean): Boolean
  3. def asDoubleStream(implicit ev: <:<[A, Double]): ScalaJDoubleStream
  4. def asIntStream(implicit ev: <:<[A, Int]): ScalaJIntStream
  5. def asJava[B >: A]: commons.JStream[B]
  6. def asLongStream(implicit ev: <:<[A, Long]): ScalaJLongStream
  7. def close(): Unit
  8. def collect[R](supplier: ⇒ R)(accumulator: (R, A) ⇒ Any, combiner: (R, R) ⇒ Any): R
  9. def collect[R, B](collector: commons.JCollector[_ >: A, B, R]): R
  10. def count: Long
  11. def distinct: ScalaJStream[A]
  12. def filter(predicate: (A) ⇒ Boolean): ScalaJStream[A]
  13. def findAny: Option[A]
  14. def findFirst: Option[A]
  15. def flatMap[R](mapper: (A) ⇒ ScalaJStream[R]): ScalaJStream[R]
  16. def flatMapToDouble(mapper: (A) ⇒ ScalaJDoubleStream): ScalaJDoubleStream
  17. def flatMapToInt(mapper: (A) ⇒ ScalaJIntStream): ScalaJIntStream
  18. def flatMapToLong(mapper: (A) ⇒ ScalaJLongStream): ScalaJLongStream
  19. def forEach(action: (A) ⇒ Any): Unit
  20. def forEachOrdered(action: (A) ⇒ Any): Unit
  21. def getClass(): Class[_ <: AnyVal]
    Definition Classes
    AnyVal → Any
  22. def isParallel: Boolean
  23. def iterator: Iterator[A]
  24. def limit(maxSize: Long): ScalaJStream[A]
  25. def map[R](mapper: (A) ⇒ R): ScalaJStream[R]
  26. def mapToDouble(mapper: (A) ⇒ Double): ScalaJDoubleStream
  27. def mapToInt(mapper: (A) ⇒ Int): ScalaJIntStream
  28. def mapToLong(mapper: (A) ⇒ Long): ScalaJLongStream
  29. def max(comparator: (A, A) ⇒ Int): Option[A]
  30. def min(comparator: (A, A) ⇒ Int): Option[A]
  31. def noneMatch(predicate: (A) ⇒ Boolean): Boolean
  32. def onClose(closeHandler: ⇒ Any): ScalaJStream[A]
  33. def parallel: ScalaJStream[A]
  34. def peek(action: (A) ⇒ Any): ScalaJStream[A]
  35. def reduce[U](identity: U)(accumulator: (U, A) ⇒ U, combiner: (U, U) ⇒ U): U
  36. def reduce[B >: A](identity: B)(accumulator: (B, B) ⇒ B): B
  37. def reduce[B >: A](accumulator: (B, B) ⇒ B): Option[B]
  38. def sequential: ScalaJStream[A]
  39. def skip(n: Long): ScalaJStream[A]
  40. def sorted(comparator: (A, A) ⇒ Int): ScalaJStream[A]
  41. def sorted: ScalaJStream[A]
  42. def to[Col[_]](implicit cbf: CanBuildFrom[Nothing, A, Col[A]]): Col[A]
  43. def toArray[B >: A <: AnyRef](implicit arg0: commons.ClassTag[B]): Array[B]
  44. def unordered: ScalaJStream[A]