stream.scala

// Copyright (c) 2013-2017 Rob Norris
// This software is licensed under the MIT License (MIT).
// For more information see LICENSE or https://opensource.org/licenses/MIT

package doobie.util

import fs2.Stream

/** Additional functions for manipulating `Stream` values. */
object stream {

  /** Stream constructor for effectful source of chunks. */
  def repeatEvalChunks[F[_], T](fa: F[Seq[T]]): Stream[F, T] =
    Stream.repeatEval(fa).takeWhile(_.nonEmpty).flatMap(Stream.emits(_))
}