Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for complete (0.18 sec)

  1. mockwebserver/README.md

    Use MockWebServer the same way that you use mocking frameworks like
    [Mockito](https://github.com/mockito/mockito):
    
    1. Script the mocks.
    2. Run application code.
    3. Verify that the expected requests were made.
    
    Here's a complete example:
    
    ```java
    public void test() throws Exception {
      // Create a MockWebServer. These are lean enough that you can create a new
      // instance for every unit test.
      MockWebServer server = new MockWebServer();
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Dec 17 15:34:10 GMT 2023
    - 5K bytes
    - Viewed (1)
  2. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

            )
            .hostnameVerifier(RecordingHostnameVerifier())
            .build()
        server.useHttps(handshakeCertificates.sslSocketFactory())
      }
    
      /** A request body that slowly trickles bytes, expecting to not complete. */
      private object SlowRequestBody : RequestBody() {
        override fun contentType(): MediaType? = null
    
        override fun writeTo(sink: BufferedSink) {
          for (i in 0 until 50) {
            sink.writeUtf8("abc")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/Call.kt

       * exception.
       *
       * @throws IllegalStateException when the call has already been executed.
       */
      fun enqueue(responseCallback: Callback)
    
      /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */
      fun cancel()
    
      /**
       * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an
       * error to execute a call more than once.
       */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 3.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              connectResult = launchTcpConnect()
              nextTcpConnectAtNanos = now + connectDelayNanos
              awaitTimeoutNanos = connectDelayNanos
            }
    
            // Wait for an in-flight connect to complete or fail.
            if (connectResult == null) {
              connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue
            }
    
            if (connectResult.isSuccess) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       *
       * The target execution time is implemented on a best-effort basis. If another task in this queue
       * is running when that time is reached, that task is allowed to complete before this task is
       * started. Similarly the task will be delayed if the host lacks compute resources.
       *
       * @throws RejectedExecutionException if the queue is shut down and the task is not cancelable.
       */
      fun schedule(
        task: Task,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  6. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

              override fun onSucceeded(
                request: UrlRequest,
                info: UrlResponseInfo,
              ) {
                println("onSucceeded ${info.headers.asMap}")
                completableFuture.complete(Response(info.httpStatusCode, info.negotiatedProtocol, buffer.readUtf8()))
              }
    
              override fun onFailed(
                request: UrlRequest,
                info: UrlResponseInfo?,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 24 13:19:43 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/ExperimentalOkHttpApi.kt

     */
    package okhttp3
    
    /**
     * Marks declarations that are experimental and subject to change without following SemVer
     * conventions. Both binary and source-incompatible changes are possible, including complete removal
     * of the experimental API.
     *
     * Do not use these APIs in modules that may be executed using a version of OkHttp different from
     * the version the module was compiled with.
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  8. docs/contribute/code_of_conduct.md

       disengages from the project, they should make it known and take the proper steps to ensure that
       others can pick up where they left off.
    
    This code is not exhaustive or complete. It serves to distill our common understanding of a
    collaborative, shared environment, and goals. We expect it to be followed in spirit as much as in
    the letter.
    
    Diversity Statement
    -------------------
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 5.1K bytes
    - Viewed (0)
  9. mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt

                val action = actions.poll() ?: break
                action(stream)
              }
            }
          }
          return@FutureTask null
        }
      }
    
      /** Returns once all stream actions complete successfully. */
      fun awaitSuccess() {
        val futureTask =
          results.poll(5, TimeUnit.SECONDS)
            ?: throw AssertionError("no onRequest call received")
        futureTask.get(5, TimeUnit.SECONDS)
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  10. samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java

       * This is potentially useful for posting live event streams like video capture. Callers should
       * write to {@code sink()} and close it to complete the post.
       */
      static final class PipeBody extends RequestBody {
        private final Pipe pipe = new Pipe(8192);
        private final BufferedSink sink = Okio.buffer(pipe.sink());
    
        public BufferedSink sink() {
    Java
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Fri Jul 06 03:18:15 GMT 2018
    - 3.1K bytes
    - Viewed (0)
Back to top