Packages

final class Apply[F[_]] extends AnyVal

See the description on IterantBuilders for the purpose of this class.

Class defined inside object due to Scala's limitations on declaring AnyVal classes.

Source
IterantBuilders.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Apply
  2. AnyVal
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Apply(v: Boolean = true)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    Any
  2. final def ##(): Int
    Definition Classes
    Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def channel[A](bufferCapacity: BufferCapacity = Bounded(recommendedBufferChunkSize), maxBatchSize: Int = recommendedBufferChunkSize, producerType: ProducerSide = MultiProducer)(implicit F: Concurrent[F], cs: ContextShift[F]): F[(ProducerF[F, Option[Throwable], A], Iterant[F, A])]

    Aliased builder, see documentation for Iterant.channel.

  6. def concatS[A](lh: F[Iterant[F, A]], rh: F[Iterant[F, A]]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.concatS.

  7. def defer[A](fa: => Iterant[F, A])(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.defer.

  8. def delay[A](a: => A)(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.eval.

  9. def empty[A]: Iterant[F, A]

    Aliased builder, see documentation for Iterant.empty.

  10. def eval[A](a: => A)(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.eval.

  11. def fromArray[A](xs: Array[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromArray.

  12. def fromBatch[A](xs: Batch[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromBatch.

  13. def fromBatchCursor[A](xs: BatchCursor[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromBatchCursor.

  14. def fromChannel[A](channel: Channel[F, A], bufferCapacity: BufferCapacity = Bounded(recommendedBufferChunkSize), maxBatchSize: Int = recommendedBufferChunkSize)(implicit F: Async[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromChannel.

  15. def fromConsumer[A](consumer: ConsumerF[F, Option[Throwable], A], maxBatchSize: Int = recommendedBufferChunkSize)(implicit F: Async[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromConsumer.

  16. def fromIndexedSeq[A](xs: IndexedSeq[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromIndexedSeq.

  17. def fromIterable[A](xs: Iterable[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromIterable.

  18. def fromIterator[A](xs: Iterator[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromIterator.

  19. def fromList[A](xs: LinearSeq[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromList.

  20. def fromReactivePublisher[A](publisher: Publisher[A], requestCount: Int = recommendedBufferChunkSize, eagerBuffer: Boolean = true)(implicit F: Async[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromReactivePublisher.

  21. def fromResource[A](r: Resource[F, A])(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromResource.

  22. def fromSeq[A](xs: Seq[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromSeq.

  23. def fromStateAction[S, A](f: (S) => (A, S))(seed: => S)(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromStateAction.

  24. def fromStateActionL[S, A](f: (S) => F[(A, S)])(seed: => F[S])(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.fromLazyStateAction.

  25. def getClass(): Class[_ <: AnyVal]
    Definition Classes
    AnyVal → Any
  26. def haltS[A](e: Option[Throwable]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.haltS.

  27. def intervalAtFixedRate(initialDelay: FiniteDuration, period: FiniteDuration)(implicit F: Async[F], timer: Timer[F]): Iterant[F, Long]

    Aliased builder, see documentation for Iterant.intervalAtFixedRate.

  28. def intervalAtFixedRate(period: FiniteDuration)(implicit F: Async[F], timer: Timer[F]): Iterant[F, Long]

    Aliased builder, see documentation for Iterant.intervalAtFixedRate.

  29. def intervalWithFixedDelay(initialDelay: FiniteDuration, delay: FiniteDuration)(implicit F: Async[F], timer: Timer[F]): Iterant[F, Long]

    Aliased builder, see documentation for Iterant.intervalAtFixedRate.

  30. def intervalWithFixedDelay(delay: FiniteDuration)(implicit F: Async[F], timer: Timer[F]): Iterant[F, Long]

    Aliased builder, see documentation for Iterant.intervalAtFixedRate.

  31. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  32. def lastS[A](item: A): Iterant[F, A]

    Aliased builder, see documentation for Iterant.lastS.

  33. def liftF[A](a: F[A])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.liftF.

  34. def never[A](implicit F: Async[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.never.

  35. def nextBatchS[A](batch: Batch[A], rest: F[Iterant[F, A]]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.nextBatchS.

  36. def nextCursorS[A](cursor: BatchCursor[A], rest: F[Iterant[F, A]]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.nextCursorS.

  37. def nextS[A](item: A, rest: F[Iterant[F, A]]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.nextS.

  38. def now[A](a: A): Iterant[F, A]

    Aliased builder, see documentation for Iterant.now.

  39. def of[A](elems: A*)(implicit F: Applicative[F]): Iterant[F, A]

    Given a list of elements build a stream out of it.

  40. def pure[A](a: A): Iterant[F, A]

    Aliased builder, see documentation for Iterant.pure.

  41. def raiseError[A](ex: Throwable): Iterant[F, A]

    Aliased builder, see documentation for Iterant.raiseError.

  42. def range(from: Int, until: Int, step: Int = 1)(implicit F: Applicative[F]): Iterant[F, Int]

    Aliased builder, see documentation for Iterant.range.

  43. def repeat[A](elems: A*)(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.repeat.

  44. def repeatEval[A](thunk: => A)(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.repeatEval.

  45. def repeatEvalF[A](fa: F[A])(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.repeatEvalF.

  46. def resource[A](acquire: F[A])(release: (A) => F[Unit])(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.resource.

  47. def resourceCase[A](acquire: F[A])(release: (A, ExitCase[Throwable]) => F[Unit])(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.resourceCase.

  48. def scopeS[A, B](acquire: F[A], use: (A) => F[Iterant[F, B]], close: (A, ExitCase[Throwable]) => F[Unit]): Iterant[F, B]

    Aliased builder, see documentation for Iterant.scopeS.

  49. def suspend[A](fa: => Iterant[F, A])(implicit F: Sync[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.suspend.

  50. def suspend[A](rest: F[Iterant[F, A]])(implicit F: Applicative[F]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.suspend.

  51. def suspendS[A](rest: F[Iterant[F, A]]): Iterant[F, A]

    Aliased builder, see documentation for Iterant.suspendS.

  52. def tailRecM[A, B](a: A)(f: (A) => Iterant[F, Either[A, B]])(implicit F: Sync[F]): Iterant[F, B]

    Aliased builder, see documentation for Iterant.tailRecM.

  53. def toString(): String
    Definition Classes
    Any
  54. val v: Boolean

Inherited from AnyVal

Inherited from Any

Ungrouped