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 and a weight limit.

Adheres to the ActorAttributes.SupervisionStrategy attribute (applied to both the key and cost functions). On Supervision.Resume the offending element is skipped; on Supervision.Restart the current group is dropped.

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(List.of("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