Hi, I have a flow of integers. I'd like to keep track of the highest value received and perform an a...

# flow

[Tony Blundell]

Hi, I have a flow of integers. I'd like to keep track of the highest value received and perform an action if a received value is greater than the highest. I'm struggling to figure out which operation I can use to do that https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/ - any ideas?

Equivalent without flows might be something like:

var highest = 0
for (i in myIntegers) {
   if (i > highest) {
      highest = i
      doSomethingElse()
   }
}

[Tony Blundell]

Turns out scan is what I was looking for 🙂

data class State(val max: Int)

    val l = flowOf(1,3,2,5,4,3,6,2,3)
            .scan(State(0)) { state, value ->
                // Do something fun with max here
                State(maxOf(state.max, value))
            }

... or while preserving the original flow...

data class State(val max: Int, val value: Int)

    val l = flowOf(1,3,2,5,4,3,6,2,3)
            .scan(State(0, 0)) { state, value ->
                // Do something fun with max here
                State(maxOf(state.max, value), value)
            }
            .drop(1)
            .map { it.value }

[elizarov]

You could have just wrapped your original code into a flow:

flow { 
    var highest = 0
    collect { i ->
       if (i > highest) {
          highest = i
          doSomethingElse()
       }
       emit(i) // emit original i
    }
}

[Tony Blundell]

True, it's good to have an option not to use mutable state though 👍