Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 282 for sing (0.04 sec)

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

      /**
       * Returns a sink that can be used to write data to the peer.
       *
       * @throws IllegalStateException if this stream was initiated by the peer and a [writeHeaders] has
       *     not yet been sent.
       */
      fun getSink(): Sink {
        this.withLock {
          check(hasResponseHeaders || isLocallyInitiated) {
            "reply before requesting the sink"
          }
        }
        return sink
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  2. internal/s3select/jstream/decoder_test.go

    	var (
    		counter int
    		mv      *MetaValue
    		body    = `{ "bio": "bada bing bada boom", "id": 1, "name": "Charles" }
    { "bio": "bada bing bada boom", "id": 2, "name": "Charles" }
    { "bio": "bada bing bada boom", "id": 3, "name": "Charles" }
    { "bio": "bada bing bada boom", "id": 4, "name": "Charles" }
    { "bio": "bada bing bada boom", "id": 5, "name": "Charles" }
    `
    	)
    
    	decoder := NewDecoder(mkReader(body), 0)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/cache2/FileOperatorTest.kt

        randomAccessFile!!.getChannel().force(false)
        val source = file!!.source().buffer()
        return source.readByteString()
      }
    
      private fun write(data: ByteString) {
        val sink = file!!.sink().buffer()
        sink.write(data)
        sink.close()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

          }
    
          override fun writeTo(sink: BufferedSink) {
            sink.writeUtf8("<el")
            sink.flush()
            throw IOException("failed to stream the XML")
          }
        }
    
        class ValidRequestBody : RequestBody() {
          override fun contentType(): MediaType {
            return "application/xml".toMediaType()
          }
    
          override fun writeTo(sink: BufferedSink) {
            sink.writeUtf8("<element/>")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/-RequestBodyCommon.kt

      return object : RequestBody() {
        override fun contentType() = contentType
    
        override fun contentLength() = byteCount.toLong()
    
        override fun writeTo(sink: BufferedSink) {
          sink.write(this@commonToRequestBody, offset, byteCount)
        }
      }
    }
    
    @Suppress("unused")
    fun RequestBody.commonContentLength(): Long = -1L
    
    @Suppress("unused")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. samples/guide/src/main/java/okhttp3/recipes/PostStreaming.java

          @Override public MediaType contentType() {
            return MEDIA_TYPE_MARKDOWN;
          }
    
          @Override public void writeTo(BufferedSink sink) throws IOException {
            sink.writeUtf8("Numbers\n");
            sink.writeUtf8("-------\n");
            for (int i = 2; i <= 997; i++) {
              sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i)));
            }
          }
    
          private String factor(int n) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Jul 06 03:18:15 UTC 2018
    - 2.1K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

          val source = this.source!!
          val sink = this.sink!!
          val tunnelCodec =
            Http1ExchangeCodec(
              // No client for CONNECT tunnels:
              client = null,
              carrier = this,
              source = source,
              sink = sink,
            )
          source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  8. common-protos/k8s.io/apimachinery/pkg/api/resource/generated.proto

    //
    // <digit>           ::= 0 | 1 | ... | 9
    // <digits>          ::= <digit> | <digit><digits>
    // <number>          ::= <digits> | <digits>.<digits> | <digits>. | .<digits>
    // <sign>            ::= "+" | "-"
    // <signedNumber>    ::= <number> | <sign><number>
    // <suffix>          ::= <binarySI> | <decimalExponent> | <decimalSI>
    // <binarySI>        ::= Ki | Mi | Gi | Ti | Pi | Ei
    //
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/convert/StringConversionUtil.java

        /** MINUS SIGN */
        public static final char MINUS_SIGN = '\u2212';
    
        /** FULLWIDTH HYPHEN-MINUS */
        public static final char FULLWIDTH_HYPHEN_MINUS = '\uFF0D';
    
        /** CENT SIGN */
        public static final char CENT_SIGN = '\u00A2';
    
        /** FULLWIDTH CENT SIGN */
        public static final char FULLWIDTH_CENT_SIGN = '\uFFE0';
    
        /** POUND SIGN */
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/io/CharSourceTest.java

        TestCharSink sink = new TestCharSink();
    
        assertFalse(sink.wasStreamOpened() || sink.wasStreamClosed());
    
        assertEquals(STRING.length(), source.copyTo(sink));
        assertTrue(source.wasStreamOpened() && source.wasStreamClosed());
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
    
        assertEquals(STRING, sink.getString());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top