waitProcessingToFinish

Waits for the transformer's current signal and effect processing to complete.

This function suspends until both the current signal processing and effect processing coroutines have finished executing. This is useful in testing scenarios where you need to ensure all transformer operations have completed before making assertions.

// Process a signal
router.process(UserSignal.Login("user", "pass"))

// Wait for transformer to finish processing
transformer.waitProcessingToFinish()

// Now safe to make assertions
val userData = queryHandler.getData(UserTransformer.dataContract)
assertNotNull(userData)