Unexpected behavior WhileSubscribed

[0x7e57]

From the documentation:

stopTimeout - configures a delay between the disappearance of the last subscriber and the stopping of the sharing coroutine.

However, stopTimeout is not refreshed on new subscriptions. I also asked this question here.
Another ephemeral example on Android:

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        val viewBinding = FragmentHomeBinding.bind(view)

        val instantFlow = flow {
            while (true) {
                emit(Instant.now())
                delay(Duration.ofMinutes(1).toMillis())
            }
        }
            .onStart { Log.d(TAG, "start") }
            .onCompletion { Log.d(TAG, "completion") }
            .shareIn(
                lifecycleScope,
                SharingStarted.WhileSubscribed(
                    Duration.ofSeconds(10).toMillis(),
                    Duration.ZERO.toMillis(),
                ),
                1,
            )
        val eventFlow = MutableSharedFlow<Unit>(
            0,
            Int.MAX_VALUE,
            BufferOverflow.SUSPEND,
        )
        viewBinding.button.setOnClickListener {
            check(eventFlow.tryEmit(Unit))
        }
        eventFlow
            .onEach { Log.d(TAG, "$it ${instantFlow.first()}") }
            .launchIn(lifecycleScope)
    }

Each click on the button should delay the completion of instantFlow, but this does not happen, the flow will end after a time equal to stopTimeout, ignoring the subscriptions that occur in eventFlow.

2021-08-09 17:32:06.835 : start
2021-08-09 17:32:06.839 : kotlin.Unit 2021-08-09T14:32:06.835Z
2021-08-09 17:32:08.411 : kotlin.Unit 2021-08-09T14:32:06.835Z
2021-08-09 17:32:09.256 : kotlin.Unit 2021-08-09T14:32:06.835Z
2021-08-09 17:32:10.978 : kotlin.Unit 2021-08-09T14:32:06.835Z
2021-08-09 17:32:12.119 : kotlin.Unit 2021-08-09T14:32:06.835Z
2021-08-09 17:32:13.964 : kotlin.Unit 2021-08-09T14:32:06.835Z
2021-08-09 17:32:16.862 : completion

I have little experience with kotlin coroutines and I may be doing something wrong. Is this the expected behavior?

[qwwdfsad]

Thanks for the report! The issue seems to have the same root cause as #2488
We'll see how we can address it.

Self-contained reproducer:

// runBlocking ctx
val instantFlow = flow {
    while (true) {
        emit(Instant.now())
        delay(Duration.ofMinutes(1).toMillis())
    }
}.onStart { println("Started") }
    .onCompletion { error("Should not be the case") }
    .shareIn(
        this,
        SharingStarted.WhileSubscribed(
            Duration.ofSeconds(5).toMillis(),
            Duration.ZERO.toMillis(),
        ),
        1,
    )
val eventFlow = flow {
    while (true) {
        emit(1)
        delay(1000)
    }
}
eventFlow
    .onEach { println("Hehe: " + instantFlow.first()) }
    .launchIn(this)
``