dropRepeated

Only pass on those elements that are distinct from the previous element.

Simple operators

Signature

Source.dropRepeatedSource.dropRepeated Flow.dropRepeatedFlow.dropRepeated

Description

Only pass on those elements that are distinct from the previous element.

Example

For example, given a Source of numbers, we just want to pass distinct numbers downstream:

Scala

copysourceSource(List(1, 2, 2, 3, 3, 1, 4))
  .dropRepeated()
  .runForeach(println)
// prints:
// 1
// 2
// 3
// 1
// 4

Java

copysourceSource.from(Arrays.asList(1, 2, 2, 3, 3, 1, 4))
    .dropRepeated()
    .runForeach(System.out::println, system);
// prints:
// 1
// 2
// 3
// 1
// 4

Reactive Streams semantics

API docs

Flow.filterFlow.filter