object Step extends Serializable
- Source
- Step.scala
- Grouped
- Alphabetic
- By Inheritance
- Step
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
consume[F[_], A](implicit arg0: Applicative[F]): Step[F, A, Vector[A]]
A Step that collects all the elements in a stream in a vector.
-
final
def
consumeIn[F[_], E, C[_]](implicit F: Applicative[F], M: MonoidK[C], C: Applicative[C]): Step[F, E, C[E]]
A Step that collects all the elements in a stream in a given collection type.
-
final
def
cont[F[_], E, A](onInput: (NonEmptyList[E]) ⇒ F[Step[F, E, A]], onEnd: F[A])(implicit F: Applicative[F]): Step[F, E, A]
Create an incomplete Step that will use the given functions to process the next input.
-
final
def
done[F[_], E, A](value: A)(implicit arg0: Applicative[F]): Step[F, E, A]
Create a new completed Step with the given result.
-
final
def
doneWithLeftovers[F[_], E, A](value: A, remaining: Seq[E])(implicit arg0: Applicative[F]): Step[F, E, A]
Create a new completed Step with the given result and leftover input.
-
final
def
drop[F[_], E](n: Int)(implicit F: Applicative[F]): Step[F, E, Unit]
A Step that drops a given number of the values from a stream.
-
final
def
dropWhile[F[_], E](p: (E) ⇒ Boolean)(implicit arg0: Applicative[F]): Step[F, E, Unit]
A Step that drops values from a stream as long as they satisfy the given predicate.
-
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] )
-
final
def
fold[F[_], E, A](init: A)(f: (A, E) ⇒ A)(implicit F: Applicative[F]): Step[F, E, A]
A Step that folds a stream using an initial value and an accumulation function.
-
final
def
foldM[F[_], E, A](init: A)(f: (A, E) ⇒ F[A])(implicit F: Monad[F]): Step[F, E, A]
A Step that folds a stream using an initial value and a monadic accumulation function.
-
final
def
foldMap[F[_], E, A](f: (E) ⇒ A)(implicit F: Applicative[F], M: Monoid[A]): Step[F, E, A]
A Step that transforms and sums values in a stream.
-
final
def
foldMapM[F[_], E, A](f: (E) ⇒ F[A])(implicit F: Applicative[F], M: Monoid[A]): Step[F, E, A]
A Step that transforms and sums values in a stream.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
head[F[_], E](implicit F: Applicative[F]): Step[F, E, Option[E]]
A Step that returns the first value in a stream.
- final def isEnd[F[_], E](implicit F: Applicative[F]): Step[F, E, Boolean]
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
joinI[F[_], A, B, C](step: Step[F, A, Step[F, B, C]])(implicit F: Monad[F]): F[Step[F, A, C]]
Collapse a nested Step into one layer.
-
final
def
last[F[_], E](implicit F: Applicative[F]): Step[F, E, Option[E]]
A Step that returns the first value in a stream.
-
final
def
length[F[_], A](implicit arg0: Applicative[F]): Step[F, A, Long]
A Step that counts the number of values in a stream.
-
final
def
liftM[F[_], E, A](fa: F[A])(implicit F: Monad[F]): F[Step[F, E, A]]
Lift an effectful value into a Step.
- final def liftMEval[F[_], E, A](fa: Eval[F[A]])(implicit F: Monad[F]): F[Step[F, E, A]]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
peek[F[_], E](implicit F: Applicative[F]): Step[F, E, Option[E]]
A Step that returns the first value in a stream without consuming it.
-
final
def
sum[F[_], E](implicit F: Applicative[F], M: Monoid[E]): Step[F, E, E]
A Step that sums of values in a stream.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- final def tailRecM[F[_], E, A, B](a: A)(f: (A) ⇒ F[Step[F, E, Either[A, B]]])(implicit arg0: Monad[F]): Step[F, E, B]
-
final
def
take[F[_], E](n: Int)(implicit arg0: Applicative[F]): Step[F, E, Vector[E]]
A Step that returns a given number of the first values in a stream.
-
final
def
takeWhile[F[_], E](p: (E) ⇒ Boolean)(implicit arg0: Applicative[F]): Step[F, E, Vector[E]]
A Step that returns values from a stream as long as they satisfy the given predicate.
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
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
- @native() @throws( ... )
- object Cont extends Serializable