- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for startCoroutine (0.14 sec)
-
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Running.kt
runToCompletion { writeOperation() } /** * [Starts][startCoroutine] the suspending [block], asserts it runs * to completion and returns its result. */ private fun <R> runToCompletion(block: suspend () -> R): R { var completion: Result<R>? = null block.startCoroutine( Continuation(EmptyCoroutineContext) { completion = it } )
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 20:48:51 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Combinators.kt
import java.io.ObjectInputStream import java.io.ObjectOutputStream import kotlin.coroutines.Continuation import kotlin.coroutines.CoroutineContext import kotlin.coroutines.coroutineContext import kotlin.coroutines.startCoroutine import kotlin.coroutines.suspendCoroutine fun <T> singleton(value: T): Codec<T> = SingletonCodec(value) fun <T> codec( encode: suspend WriteContext.(T) -> Unit,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:59:39 UTC 2024 - 8.4K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
// deterministic and because there is no real work anyway. par := cfg.BuildP if cfg.BuildN { par = 1 } for i := 0; i < par; i++ { wg.Add(1) go func() { ctx := trace.StartGoroutine(ctx) defer wg.Done() for { select { case _, ok := <-b.readySema: if !ok { return } // Receiving a value from b.readySema entitles
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0)