groupedAdjacentBy

Partitions this stream into chunks by a delimiter function.

Simple operators

Signature

Source.groupedAdjacentBySource.groupedAdjacentBy Flow.groupedAdjacentByFlow.groupedAdjacentBy

Description

Partitions this stream into chunks by a delimiter function.

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

See also:

• groupedAdjacentByWeighted for a variant that groups with weight limit too.

Examples

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

Scala

copysourceSource(List("Hello", "Hi", "Greetings", "Hey"))
  .groupedAdjacentBy(_.head)
  .runForeach(println)
// prints:
// Vector(Hello, Hi)
// Vector(Greetings)
// Vector(Hey)

Java

copysourceSource.from(List.of("Hello", "Hi", "Greetings", "Hey"))
    .groupedAdjacentBy(str -> str.charAt(0))
    .runForeach(System.out::println, system);
// prints:
// [Hello, Hi]
// [Greetings]
// [Hey]

Reactive Streams semantics