This repository has been archived by the owner on Feb 23, 2022. It is now read-only.
Added a .cleanUp()
method to cancel coroutine Jobs and channels and release recorded emissions to avoid running out of memory if you have a lot of emissions recorded and a lot of tests doing that. Discussed in #2 .
val emissions = flowOf(1,2,3).record()
emissions shouldEmitNext 1
emissions.shouldEmitNext(2,3)
emissions.cleanUp() // <-- new in 0.2.0