groupedAdjacentByWeighted

Partitions this stream into chunks by a delimiter function and a weight limit.

Simple operators

Signature

Source.groupedAdjacentByWeightedSource.groupedAdjacentByWeighted Flow.groupedAdjacentByWeightedFlow.groupedAdjacentByWeighted

Description

Partitions this stream into chunks by a delimiter function.

See also:

• groupedAdjacentBy for a simpler variant.

Examples

The example below demonstrates how groupedAdjacentByWeighted partitions the elements into Seq List.

Scala

copysourceSource(List("Hello", "HiHi", "Hi", "Hi", "Greetings", "Hey"))
  .groupedAdjacentByWeighted(_.head, 4)(_.length)
  .runForeach(println)
// prints:
// Vector(Hello)
// Vector(HiHi)
// Vector(Hi, Hi)
// Vector(Greetings)
// Vector(Hey)

Java

copysourceSource.from(Arrays.asList("Hello", "HiHi", "Hi", "Hi", "Greetings", "Hey"))
    .groupedAdjacentByWeighted(str -> str.charAt(0), 4, str -> (long) str.length())
    .runForeach(System.out::println, system);
// prints:
// [Hello]
// [HiHi]
// [Hi, Hi]
// [Greetings]
// [Hey]

Reactive Streams semantics