object
StreamT
extends Extras
Type Members
-
type
->
[A, B]
= ~>[[B]A, [B]B]
-
type
Id
[A]
= A
-
trait
Konst
[A]
extends AnyRef
-
case class
Skip
[+S]
(s: S) extends Step[Nothing, S] with Product with Serializable
-
class
Step
[+A, +S]
extends AnyRef
-
type
Thunk
[A]
= () ⇒ A
-
case class
Yield
[+A, +S]
(a: A, s: S) extends Step[A, S] with Product with Serializable
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
object
Done
extends Step[Nothing, Nothing] with Product with Serializable
-
def
apply
[M[_], A]
(step: ⇒ M[Step[A, StreamT[M, A]]]): StreamT[M, A]
-
def
asInstanceOf
[T0]
: T0
-
def
clone
(): AnyRef
-
def
empty
[M[_], A]
(implicit M: Pure[M]): StreamT[M, A]
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
def
fromIterable
[A]
(s: Iterable[A]): StreamT[Id, A]
-
def
getClass
(): java.lang.Class[_]
-
def
hashCode
(): Int
-
def
id
: ~>[Id, Id]
-
val
idMonad
: Monad[Id]
-
def
isInstanceOf
[T0]
: Boolean
-
implicit def
natToFunction
[F[_], G[_], A]
(f: ~>[F, G]): (F[A]) ⇒ G[A]
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
runStreamT
[S, A]
(stream: StreamT[[X]State[S, X], A], s0: S): StreamT[Id, A]
-
implicit def
streamTBind
[M[_]]
(implicit arg0: Functor[M]): Bind[[X]StreamT[M, X]]
-
implicit def
streamTEmpty
[M[_]]
(implicit arg0: Pure[M]): Empty[[X]StreamT[M, X]]
-
implicit def
streamTFunctor
[M[_]]
(implicit arg0: Functor[M]): Functor[[X]StreamT[M, X]]
-
implicit def
streamTPure
[M[_]]
(implicit arg0: Pure[M]): Pure[[X]StreamT[M, X]]
-
implicit def
streamTSemigroup
[M[_], A]
(implicit arg0: Functor[M]): Semigroup[StreamT[M, A]]
-
implicit def
streamTZero
[M[_], A]
(implicit arg0: Pure[M]): Zero[StreamT[M, A]]
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
unfold
[A, B]
(b: B)(f: (B) ⇒ Option[(A, B)]): StreamT[Id, A]
-
def
unfoldM
[M[_], A, B]
(start: B)(f: (B) ⇒ M[Option[(A, B)]])(implicit M: Functor[M]): StreamT[M, A]
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
def
wrapEffect
[M[_], A]
(m: M[StreamT[M, A]])(implicit arg0: Functor[M]): StreamT[M, A]
Inherited from AnyRef
Inherited from Any