trait Producers extends AnyRef

Linear Supertypes
AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Producers
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def chunk[R, A](size: Int)(producer: Producer[R, A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]

    accumulate chunks of size n inside More nodes

  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  7. def collect[R, A](producer: Producer[R, A])(implicit arg0: eff.all._Safe[R], m: Member[[β$4$]Writer[A, β$4$], R]): Eff[R, Unit]
  8. def done[R, A](implicit arg0: eff.all._Safe[R]): Producer[R, A]
  9. def emit[R, A](elements: List[A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  10. def emitEff[R, A](elements: Eff[R, List[A]])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  11. def emitSeq[R, A](elements: Seq[A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  12. def empty[R, A](implicit arg0: eff.all._Safe[R]): Producer[R, A]
  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  15. def eval[R, A](a: Eff[R, A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  16. def evalProducer[R, A](a: Eff[R, Producer[R, A]])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  17. def fill[R, A](n: Int)(p: Producer[R, A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  18. def filter[R, A](producer: Producer[R, A])(f: (A) ⇒ Boolean)(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  19. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  20. def flatten[R, A](producer: Producer[R, Producer[R, A]])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  21. def flattenList[R, A](producer: Producer[R, List[A]])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  22. def flattenProducers[R, A](producers: List[Producer[R, A]])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  23. def flattenSeq[R, A](producer: Producer[R, Seq[A]])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  24. def fold[R, A, B, S](producer: Producer[R, A])(start: Eff[R, S], f: (S, A) ⇒ Eff[R, S], end: (S) ⇒ Eff[R, B])(implicit arg0: eff.all._Safe[R]): Eff[R, B]
  25. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  26. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  27. def into[R, U, A](producer: Producer[R, A])(implicit intoPoly: IntoPoly[R, U], s: eff.all._Safe[U]): Producer[U, A]
  28. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  29. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  32. def observe[R, A, S](producer: Producer[R, A])(start: Eff[R, S], f: (S, A) ⇒ S, end: (S) ⇒ Eff[R, Unit])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  33. def one[R, A](a: A)(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  34. def oneEff[R, A](e: Eff[R, A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  35. def oneOrMore[R, A](a: A, as: List[A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  36. def peek[R, A](producer: Producer[R, A])(implicit arg0: eff.all._Safe[R]): Eff[R, (Option[A], Producer[R, A])]
  37. def peekN[R, A](producer: Producer[R, A], n: Int)(implicit arg0: eff.all._Safe[R]): Eff[R, (List[A], Producer[R, A])]
  38. def pipe[R, A, B](p: Producer[R, A], t: Transducer[R, A, B]): Producer[R, B]
  39. def repeat[R, A](p: Producer[R, A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  40. def repeatEval[R, A](e: Eff[R, A])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  41. def repeatValue[R, A](a: A)(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  42. def runLast[R, A](producer: Producer[R, A])(implicit arg0: eff.all._Safe[R]): Eff[R, Option[A]]
  43. def runList[R, A](producer: Producer[R, A])(implicit arg0: eff.all._Safe[R]): Eff[R, List[A]]
  44. def sequence[R, F[_], A](n: Int)(producer: Producer[R, Eff[R, A]])(implicit arg0: eff.all._Safe[R]): Producer[R, A]
  45. def sliding[R, A](size: Int)(producer: Producer[R, A])(implicit arg0: eff.all._Safe[R]): Producer[R, List[A]]
  46. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  47. def toString(): String
    Definition Classes
    AnyRef → Any
  48. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped