Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 744 for Executed (0.22 sec)

  1. okhttp/src/test/java/okhttp3/OpenJSSETest.kt

      }
    
      @Test
      fun testTlsv13Works() {
        enableTls()
    
        server.enqueue(MockResponse(body = "abc"))
    
        val request = Request(server.url("/"))
    
        val response = client.newCall(request).execute()
    
        response.use {
          assertEquals(200, response.code)
          assertEquals(TlsVersion.TLS_1_3, response.handshake?.tlsVersion)
          assertEquals(Protocol.HTTP_2, response.protocol)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. build-logic/documentation/src/test/groovy/gradlebuild/docs/model/SimpleClassMetaDataRepositoryTest.groovy

            repository.put('class1', value1)
            repository.put('class2', value2)
            Action action = Mock()
    
            when:
            repository.each(action)
    
            then:
            1 * action.execute(value1)
            1 * action.execute(value2)
            0 * action._
        }
    
        def canPersistMetaData() {
            TestDomainObject value = new TestDomainObject('a')
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Sat Apr 06 02:21:33 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. samples/guide/src/main/java/okhttp3/recipes/CacheResponse.java

        Request request = new Request.Builder()
            .url("http://publicobject.com/helloworld.txt")
            .build();
    
        String response1Body;
        try (Response response1 = client.newCall(request).execute()) {
          if (!response1.isSuccessful()) throw new IOException("Unexpected code " + response1);
    
          response1Body = response1.body().string();
          System.out.println("Response 1 response:          " + response1);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun May 22 01:29:42 UTC 2016
    - 2.4K bytes
    - Viewed (0)
  4. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/lifecycle/Execution.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.plugin.lifecycle;
    
    /**
     * A set of goals to execute.
     *
     * @version $Revision$ $Date$
     */
    @SuppressWarnings("all")
    public class Execution implements java.io.Serializable {
    
        // --------------------------/
        // - Class/Member Variables -/
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/SocksProxy.kt

      private val connectionCount = AtomicInteger()
      private val openSockets = Collections.newSetFromMap(ConcurrentHashMap<Socket, Boolean>())
    
      fun play() {
        serverSocket = ServerSocket(0)
        executor.execute {
          val threadName = "SocksProxy ${serverSocket!!.localPort}"
          Thread.currentThread().name = threadName
          try {
            while (true) {
              val socket = serverSocket!!.accept()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/DefaultEncryptInvoker.java

                header.add(asb.toAttributedString());
            }
        }
    
        public DefaultEncryptInvoker(ProtoLookup protoLookup) {
            super(protoLookup);
        }
    
        @Override
        protected int execute(LocalContext context) throws Exception {
            return doExecute(context);
        }
    
        @Override
        protected LocalContext createContext(EncryptInvokerRequest invokerRequest) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

        this.client = client;
      }
    
      private void parallelDrainQueue(int threadCount) {
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);
        for (int i = 0; i < threadCount; i++) {
          executor.execute(() -> {
            try {
              drainQueue();
            } catch (Exception e) {
              e.printStackTrace();
            }
          });
        }
        executor.shutdown();
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  8. mockwebserver-junit5/src/test/java/mockwebserver3/junit5/internal/ExtensionLifecycleTest.kt

        clientTestRule.newClient().newCall(Request(server.url("/"))).execute().use {
          assertThat(it.code).isEqualTo(200)
        }
      }
    
      @Test
      fun testClient2(server: MockWebServer) {
        assertThat(server).isSameInstanceAs(instanceServer)
    
        clientTestRule.newClient().newCall(Request(server.url("/"))).execute().use {
          assertThat(it.code).isEqualTo(200)
        }
      }
    
      @ParameterizedTest
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 11 12:12:36 UTC 2024
    - 3K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        }
    
        @CanIgnoreReturnValue
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
          }
          executionList.execute();
          if (mayInterruptIfRunning) {
            interruptTask();
          }
          return true;
        }
    
        /**
         * Subclasses can override this method to implement interruption of the future's computation.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. okhttp-brotli/src/test/java/okhttp3/brotli/BrotliTestMain.kt

      sendRequest("https://httpbin.org/gzip", client)
    }
    
    private fun sendRequest(
      url: String,
      client: OkHttpClient,
    ) {
      val req = Request.Builder().url(url).build()
    
      client.newCall(req).execute().use {
        println(it.body.string())
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.1K bytes
    - Viewed (0)
Back to top