New Iterant operators:

sealed abstract class Iterant[F[_], A] {

  def batched(count: Int)(implicit F: Sync[F]): Iterant[F, A]

  def bufferTumbling(count: Int)(implicit F: Sync[F]): Iterant[F, Seq[A]]
 
  def bufferSliding(count: Int, skip: Int)(implicit F: Sync[F]): Iterant[F, Seq[A]] =
}

These all share the same implementation, more or less:

1. bufferSliding is the exact equivalent of the sliding operation on Scala's collection or of Observable.bufferSliding
2. bufferTumbling(count) is a handy alias for bufferSliding(count, count)
3. batched(count) is equivalent with bufferTumbling(count), however what it does is to emit NextBatch nodes, thus hiding the actual batches being emitted in the underlying implementation - this operator is useful for optimizing the representation of the source

Example for bufferSliding given in the docs:

val source = Iterant[Coeval].of(1, 2, 3, 4, 5, 6, 7)

// Yields Seq(1, 2, 3), Seq(4, 5, 6), Seq(7)
source.bufferSliding(3, 3)

// Yields Seq(1, 2, 3), Seq(5, 6, 7)
source.bufferSliding(3, 4)

// Yields Seq(1, 2, 3), Seq(3, 4, 5), Seq(5, 6, 7)
source.bufferSliding(3, 2)