Searched refs:tryEmit (Results 1 – 6 of 6) sorted by relevance
113 assertFalse(sh.tryEmit(5)) // collector is not ready now in <lambda>()132 assertFalse(sh.tryEmit(13)) // rendezvous does not work this way in <lambda>()228 assertTrue(sh.tryEmit(3)) // buffered in <lambda>()232 assertTrue(sh.tryEmit(5)) // buffered in <lambda>()247 assertFalse(sh.tryEmit(10)) // still no buffer space in <lambda>()267 assertTrue(sh.tryEmit(0)) in <lambda>()291 assertTrue(sh.tryEmit(1)) // buffered in <lambda>()293 assertTrue(sh.tryEmit(2)) // buffered in <lambda>()295 assertTrue(sh.tryEmit(3)) // buffered (buffer size is 3) in <lambda>()301 assertTrue(sh.tryEmit(4)) // can buffer now in <lambda>()[all …]
150 public fun tryEmit(value: T): Boolean in tryEmit() method322 override fun tryEmit(value: T): Boolean { in tryEmit() method in kotlinx.coroutines.flow.SharedFlowImpl337 if (tryEmit(value)) return // fast-path in emit()
313 override fun tryEmit(value: T): Boolean { in tryEmit() method
225 … shared.tryEmit(initialValue) // state flow -> reset to initial value in launchSharing()
1769 llvm::Constant *tryEmit();1817 llvm::Constant *ConstantLValueEmitter::tryEmit() { in tryEmit() function in ConstantLValueEmitter2041 return ConstantLValueEmitter(*this, Value, DestType).tryEmit(); in tryEmitPrivate()
1069 public abstract fun tryEmit (Ljava/lang/Object;)Z