suspend fun producer() = flow {}

private suspend packetFlow(...): Flow<ResponsePacket> {
  return producer()
     .transformWhile {
        // how to launch coroutine here that does not block?
        // coroutineScope {} blocks so it's not an option
        launch {
          delay(2000L)
          state = 1 // set state
          return@transformWhile false // terminate flow
        }
     }
}

flow {
    withTimeoutOrNull(2000L) {
        emitAll(producer())
    }
}

suspend fun producer() = flow {
  while(true) {
     //Bluetooth input stream
  }
}

transformWhile

channelFlow

private suspend packetFlow(...): Flow<ResponsePacket> = channelFlow {
  launch {  
	producer()
     .transformWhile {
	   while(condition) {
	    
			launch {
			  delay(2000L)
			  isLastPacket = 1 // set state
			  // When coroutine finished nothing happens. It does not recover
			}

            // I would expect to recover from coroutine here
	    }
		
		// Leave flow if false
		return@transformWhile !isLastPacket
     }.collect()
  }