Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for Continuation (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/package-info.java

     *  </p>
     *  <p><code>WriteContext.write(object)</code> then delegates to {@link org.gradle.internal.serialize.graph.Codec#encode(WriteContext, java.lang.Object, kotlin.coroutines.Continuation) Codec.encode(WriteContext, Object)}.</p>
     *  <p>A codec implementation will, generally:
     *  <ul>
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/utils/KtFe10TypeSystemCommonBackendContextForTypeMapping.kt

            }
    
            return upperBounds.firstOrNull() ?: builtIns.nullableAnyType
        }
    
        override fun continuationTypeConstructor(): TypeConstructorMarker {
            val continuationFqName = StandardClassIds.Continuation.asSingleFqName()
            val foundClasses = resolveSession.getTopLevelClassifierDescriptors(continuationFqName, NoLookupLocation.FROM_IDE)
            return foundClasses.firstOrNull()?.typeConstructor
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed May 22 06:28:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    		// ResourceVersion should be unset when setting continuation token.
    		ResourceVersion: "",
    		Predicate:       pred(0, continueFromSecondItem),
    		Recursive:       true,
    	}
    	if err := store.GetList(ctx, "/pods", options, out); err != nil {
    		t.Fatalf("Unable to get second page: %v", err)
    	}
    	if len(out.Continue) != 0 {
    		t.Fatalf("Unexpected continuation token set")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  9. src/net/textproto/reader.go

    	return line, nil
    }
    
    // ReadContinuedLine reads a possibly continued line from r,
    // eliding the final trailing ASCII white space.
    // Lines after the first are considered continuations if they
    // begin with a space or tab character. In the returned data,
    // continuation lines are separated from the previous line
    // only by a single space: the newline and leading white space
    // are removed.
    //
    // For example, consider this input:
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  10. src/runtime/debugcall.go

    	// Undo the lockOSThread we did earlier.
    	unlockOSThread()
    
    	gp.asyncSafePoint = false
    }
    
    type debugCallWrapArgs struct {
    	dispatch uintptr
    	callingG *g
    }
    
    // debugCallWrap1 is the continuation of debugCallWrap on the callee
    // goroutine.
    func debugCallWrap1() {
    	gp := getg()
    	args := (*debugCallWrapArgs)(gp.param)
    	dispatch, callingG := args.dispatch, args.callingG
    	gp.param = nil
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 05 20:50:21 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top