Luis Munoz
04/09/2020, 7:08 PMDominaezzz
04/09/2020, 7:25 PMErik
04/09/2020, 9:10 PMLuis Munoz
04/09/2020, 11:38 PMmerge(sampling(), samplingCheckFlow()).flowOn(context)
private fun samplingCheckFlow() : Flow<String> {
return flow<String> {
<http://Log.info|Log.info>().log("cehcking flow!")
while(isSampling.get()) { delay(1000L) }
<http://Log.info|Log.info>().log("[kafka sampling] - throw cancellation")
throw CancellationException("not sampling")
}
}
Dominaezzz
04/10/2020, 1:12 AMrkeazor
04/10/2020, 3:06 AMLuis Munoz
04/10/2020, 5:11 PM