Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 127 for Read (0.39 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt

      ): Boolean
    
      /**
       * A chunk of response data corresponding to a pushed request.  This data must either be read or
       * skipped.
       *
       * @param streamId server-initiated stream ID: an even number.
       * @param source location of data corresponding with this stream ID.
       * @param byteCount number of bytes to read or skip from the source.
       * @param last when true, there are no data frames to follow.
       */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

          }
    
        /**
         * Sets the default read timeout for new connections. A value of 0 means no timeout, otherwise
         * values must be between 1 and [Integer.MAX_VALUE] when converted to milliseconds.
         *
         * The read timeout is applied to both the TCP socket and for individual read IO operations
         * including on [Source] of the [Response]. The default value is 10 seconds.
         *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:21:33 GMT 2024
    - 52K bytes
    - Viewed (0)
  3. samples/tlssurvey/src/main/kotlin/okhttp3/survey/Clients.kt

          ConnectionSpec.COMPATIBLE_TLS.cipherSuites!!.map {
            ianaSuites.fromJavaName(it.javaName)
          },
      )
    }
    
    fun historicOkHttp(version: String): Client {
      val enabled =
        FileSystem.RESOURCES.read("okhttp_$version.txt".toPath()) {
          this.readUtf8().lines().filter { it.isNotBlank() }.map {
            SuiteId(id = null, name = it.trim())
          }
        }
      return Client(
        userAgent = "OkHttp",
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Apr 02 01:44:15 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  4. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

      private val fileSystem = FileSystem.SYSTEM
    
      private fun readStory(source: BufferedSource): Story {
        return STORY_JSON_ADAPTER.fromJson(source)!!
      }
    
      private fun readStory(file: Path): Story {
        fileSystem.read(file) {
          return readStory(this)
        }
      }
    
      /** Iterate through the hpack-test-case resources, only picking stories for the current draft.  */
      fun storiesForCurrentDraft(): Array<String> {
        val resource =
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

        val b1 = source.readByte() and 0xff
    
        val isMasked = b1 and B1_FLAG_MASK != 0
        if (isMasked == isClient) {
          // Masked payloads must be read on the server. Unmasked payloads must be read on the client.
          throw ProtocolException(
            if (isClient) {
              "Server-sent frames must not be masked."
            } else {
              "Client-sent frames must be masked."
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.8K bytes
    - Viewed (0)
  6. .github/workflows/containers.yml

    name: containers
    
    on:
      push:
        branches:
          - master
      pull_request:
        types: [opened, labeled, unlabeled, synchronize]
    
    permissions:
      contents: read
    
    env:
      GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false"
    
    jobs:
      test_containers:
        permissions:
          checks: write # for actions/upload-artifact
        runs-on: ubuntu-latest
    Others
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Mar 23 12:00:11 GMT 2024
    - 911 bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/Call.kt

       *
       * ```java
       * // ensure the response (and underlying response body) is closed
       * try (Response response = client.newCall(request).execute()) {
       *   ...
       * }
       * ```
       *
       * The caller may read the response body with the response's [Response.body] method. To avoid
       * leaking resources callers must [close the response body][ResponseBody] or the response.
       *
    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)
  8. okhttp/src/main/kotlin/okhttp3/CertificatePinner.kt

     * [static certificates][static_certificates].
     *
     * ## Setting up Certificate Pinning
     *
     * The easiest way to pin a host is turn on pinning with a broken configuration and read the
     * expected configuration when the connection fails. Be sure to do this on a trusted network, and
     * without man-in-the-middle tools like [Charles][charles] or [Fiddler][fiddler].
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 14.2K bytes
    - Viewed (1)
  9. okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt

            add(ia.next())
          }
          if (ib.hasNext()) {
            add(ib.next())
          }
        }
      }
    }
    
    // TODO check read only options for creating lists
    public fun <T> List<T>.readOnly() = this.toList()
    
    // TODO check read only options for creating lists
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 11K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/SocksProxy.kt

        }
      }
    
      private fun acceptCommand(
        fromAddress: InetAddress,
        fromSource: BufferedSource,
        fromSink: BufferedSink,
      ) {
        // Read the command.
        val version = fromSource.readByte() and 0xff
        if (version != VERSION_5) throw ProtocolException("unexpected version: $version")
    
        val command = fromSource.readByte() and 0xff
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 7.7K bytes
    - Viewed (0)
Back to top