- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Continuation (0.15 sec)
-
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) } override fun onResponse( call: Call,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 1.5K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/resolver/KotlinBuildScriptModelRepository.kt
import org.gradle.kotlin.dsl.concurrent.ResurrectingThread import org.gradle.kotlin.dsl.tooling.models.KotlinBuildScriptModel import kotlin.coroutines.Continuation import kotlin.coroutines.suspendCoroutine private typealias AsyncModelRequest = Pair<KotlinBuildScriptModelRequest, Continuation<KotlinBuildScriptModel?>> internal open class KotlinBuildScriptModelRepository {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 2.9K bytes - Viewed (0) -
src/mime/mediatype.go
} pmap := params if baseName, _, ok := strings.Cut(key, "*"); ok { if continuation == nil { continuation = make(map[string]map[string]string) } var ok bool if pmap, ok = continuation[baseName]; !ok { continuation[baseName] = make(map[string]string) pmap = continuation[baseName] } } if v, exists := pmap[key]; exists && v != value {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.8K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Combinators.kt
} ) } while (decodeCall != null) return result } } private class DecodeFrame<T>(val k: Continuation<T>?) private data class EncodeFrame<T>(val value: T, val k: Continuation<Unit>?) private data class SingletonCodec<T>( private val singleton: T ) : Codec<T> { override suspend fun WriteContext.encode(value: 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) -
cmd/api-resources.go
func getListObjectsV2Args(values url.Values) (prefix, token, startAfter, delimiter string, fetchOwner bool, maxkeys int, encodingType string, errCode APIErrorCode) { errCode = ErrNone // The continuation-token cannot be empty. if val, ok := values["continuation-token"]; ok { if len(val[0]) == 0 { errCode = ErrIncorrectContinuationToken return } } if values.Get("max-keys") != "" { var err error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 07 18:25:26 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/native/language-native/src/test/groovy/org/gradle/language/nativeplatform/internal/incremental/sourceparser/PreprocessingReaderTest.groovy
"\\"" ''' then: output == '\n"abc\\""\n"\\""' } def "removes line continuation characters"() { when: input = """Here is a ${BN}single line ${BN}with continuations \\${BN}and \\ slashes\\\t\n too\\ \n.""" then: output == "Here is a single line with continuations \\and \\ slashes\\\t\n too\\ \n." } def "replaces inline comments with space"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 4.2K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Running.kt
* limitations under the License. */ package org.gradle.internal.serialize.graph import kotlin.contracts.InvocationKind import kotlin.contracts.contract import kotlin.coroutines.Continuation import kotlin.coroutines.EmptyCoroutineContext import kotlin.coroutines.startCoroutine /** * Runs the given [readOperation] synchronously. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 20:48:51 UTC 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
private val FRAME_NAMES = arrayOf( "DATA", "HEADERS", "PRIORITY", "RST_STREAM", "SETTINGS", "PUSH_PROMISE", "PING", "GOAWAY", "WINDOW_UPDATE", "CONTINUATION", ) /** * Lookup table for valid flags for DATA, HEADERS, CONTINUATION. Invalid combinations are * represented in binary. */ private val FLAGS = arrayOfNulls<String>(0x40) // Highest bit flag is 0x20. private val BINARY =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.7K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/concurrent/future.kt
import java.util.concurrent.CountDownLatch import java.util.concurrent.Future import java.util.concurrent.TimeUnit import java.util.concurrent.TimeoutException import kotlin.coroutines.Continuation import kotlin.coroutines.CoroutineContext import kotlin.coroutines.EmptyCoroutineContext import kotlin.coroutines.startCoroutine /** * Starts and exposes the given suspending [computation] as a [Future] value.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 2.2K bytes - Viewed (0) -
okhttp-coroutines/api/okhttp-coroutines.api
public final class okhttp3/coroutines/ExecuteAsyncKt { public static final fun executeAsync (Lokhttp3/Call;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 163 bytes - Viewed (0)