Searched refs:collector2 (Results 1 – 2 of 2) sorted by relevance
20 let collector2 = collector.clone(); in it_works() localVariable24 let guard = collector2.register().pin(); in it_works()
404 val collector2 = sh.onEach { in <lambda>() constant429 collector2.cancel() in <lambda>()