Greetings, seems like I misunderstand

shareIn

functionality. Trying to share the flow emitions betwenn 3 subscribers, but only one of them (first) is collecting data:

@Test
  fun testSharedFlowEmitions() = runBlocking {
    var tick = 0
    val f: Flow<Int> = flow {
      while (tick < 10) {
        emit(tick)
        tick++
      }
    }

    val sharedFlow: SharedFlow<Int> = f.shareIn(this, SharingStarted.Eagerly, replay = 1)

    val firstSubscriber = sharedFlow.collect { Truth.assertThat(it).isGreaterThan(0) }
    val secondSubscriber = sharedFlow.collect { Truth.assertThat(it).isGreaterThan(0) }
    val thirdSubscriber = sharedFlow.collect { Truth.assertThat(it).isGreaterThan(0) }
  }

Need help so that all three get ticks.

you can collect in a

launch

, or do

onEach { }.launchIn(scope)

instead, that way the collections would happen in parallel (you can still lose some events though, since you’re starting the shared flow eagerly)