- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,128 for coll (0.08 sec)
-
internal/dsync/dsync-client_test.go
return errLockNotFound } return err } // Call makes a REST call to the remote endpoint using the msgp codec func (restClient *ReconnectRESTClient) Call(method string, args LockArgs) (status bool, err error) { buf, err := args.MarshalMsg(nil) if err != nil { return false, err } body := bytes.NewReader(buf) respBody, err := restClient.rest.Call(context.Background(), method, url.Values{}, body, body.Size())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/HttpsServer.java
.sslSocketFactory(clientCertificates.sslSocketFactory(), clientCertificates.trustManager()) .build(); Call call = client.newCall(new Request.Builder() .url(server.url("/")) .build()); Response response = call.execute(); System.out.println(response.handshake().tlsVersion()); } public static void main(String... args) throws Exception {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 02 14:04:37 UTC 2023 - 2.1K bytes - Viewed (0) -
android-test-app/src/main/kotlin/okhttp/android/testapp/MainActivity.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.5K bytes - Viewed (0) -
build-logic-commons/code-quality-rules/src/main/java/gradlebuild/codenarc/rules/IntegrationTestFixtureVisitor.java
private void checkOutputContains(MethodCallExpression call) { ASTNode receiver = call.getReceiver(); if (receiver instanceof PropertyExpression) { if (((PropertyExpression) receiver).getPropertyAsString().equals("output")) { Expression objectExpr = ((PropertyExpression) receiver).getObjectExpression(); checkIndirectOutputContains(objectExpr, call); } } }
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 2.9K bytes - Viewed (0) -
src/main/webapp/js/admin/bootstrap.min.js
t=t,this._config=this._getConfig(e),this._triggerArray=[].slice.call(document.querySelectorAll('[data-toggle="collapse"][href="#'+t.id+'"],[data-toggle="collapse"][data-target="#'+t.id+'"]'));for(var n=[].slice.call(document.querySelectorAll(U)),i=0,o=n.length;i<o;i++){var a=n[i],s=d.getSelectorFromElement(a),l=[].slice.call(document.querySelectorAll(s)).filter((function(e){return e===t}));null!==s&&l.length>0&&(this._selector=s,this._triggerArray.push(a))}this._parent=this._config.parent?this._...
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 61.1K bytes - Viewed (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
} this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) } override fun onResponse( call: Call, response: Response, ) { continuation.resume(response) { response.closeQuietly() } } }, )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
class CacheInterceptor(internal val cache: Cache?) : Interceptor { @Throws(IOException::class) override fun intercept(chain: Interceptor.Chain): Response { val call = chain.call() val cacheCandidate = cache?.get(chain.request().requestForCache()) val now = System.currentTimeMillis() val strategy = CacheStrategy.Factory(now, chain.request(), cacheCandidate).compute()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Mar 22 07:09:21 UTC 2024 - 10.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
public void testPoll_empty() { assertNull("emptyQueue.poll() should return null", getQueue().poll()); expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testPoll_size1() { assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); expectMissing(e0()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jul 24 20:12:35 UTC 2024 - 2.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental_reader_test.cc
TF_DeleteStatus(status); return counter; } void IncrementCounter0(TFE_MonitoringCounter0* counter, int64_t delta) { auto* cell = TFE_MonitoringGetCellCounter0(counter); TFE_MonitoringCounterCellIncrementBy(cell, delta); } TFE_MonitoringCounter1* CreateCounter1(const char* counter_name, const char* label) { TF_Status* status = TF_NewStatus();
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 20 03:14:47 UTC 2023 - 2.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Table.java
* * @since 7.0 */ interface Cell< R extends @Nullable Object, C extends @Nullable Object, V extends @Nullable Object> { /** Returns the row key of this cell. */ @ParametricNullness R getRowKey(); /** Returns the column key of this cell. */ @ParametricNullness C getColumnKey(); /** Returns the value of this cell. */ @ParametricNullness V getValue();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Jun 17 14:40:53 UTC 2023 - 10.7K bytes - Viewed (0)