Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,128 for coll (0.08 sec)

  1. 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)
  2. 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)
  3. android-test-app/src/main/kotlin/okhttp/android/testapp/MainActivity.kt

        client.newCall(Request(url)).enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              println("failed: $e")
            }
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              println("response: ${response.code}")
              response.close()
            }
          },
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top