Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 287 for sing (0.04 sec)

  1. 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)
  2. okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt

        val pipe = Pipe(1024)
        val sink = pipe.sink.buffer()
        val relay = edit(file, pipe.source, metadata, 5)
        val future1 = executor.submit(sourceReader(relay.newSource()))
        val future2 = executor.submit(sourceReader(relay.newSource()))
        Thread.sleep(500)
        sink.writeUtf8("abcdefghij")
        Thread.sleep(500)
        sink.writeUtf8("klmnopqrst")
        sink.close()
        assertThat<ByteString>(future1.get())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. src/main/resources/fess_indices/fess/fi/stopwords.txt

    olisivat
    olit
    olin
    olimme
    olitte
    olivat
    ollut
    olleet
    en
    et
    ei
    emme
    ette
    eivät
    minä
    minun
    minut
    minua
    minussa
    minusta
    minuun
    minulla
    minulta
    minulle
    sinä
    sinun
    sinut
    sinua
    sinussa
    sinusta
    sinuun
    sinulla
    sinulta
    sinulle
    hän
    hänen
    hänet
    häntä
    hänessä
    hänestä
    häneen
    hänellä
    häneltä
    hänelle
    me
    meidän
    meidät
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Nov 27 12:59:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  4. internal/event/target/redis.go

    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *RedisTarget) isActive() (bool, error) {
    	conn := target.pool.Get()
    	defer conn.Close()
    
    	_, pingErr := conn.Do("PING")
    	if pingErr != nil {
    		if xnet.IsConnRefusedErr(pingErr) {
    			return false, store.ErrNotConnected
    		}
    		return false, pingErr
    	}
    	return true, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. src/archive/tar/strconv.go

    		return strconv.FormatInt(secs, 10)
    	}
    
    	// If seconds is negative, then perform correction.
    	sign := ""
    	if secs < 0 {
    		sign = "-"             // Remember sign
    		secs = -(secs + 1)     // Add a second to secs
    		nsecs = -(nsecs - 1e9) // Take that second away from nsecs
    	}
    	return strings.TrimRight(fmt.Sprintf("%s%d.%09d", sign, secs, nsecs), "0")
    }
    
    // parsePAXRecord parses the input PAX record string into a key-value pair.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 01 14:28:42 UTC 2023
    - 9K bytes
    - Viewed (0)
  6. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt

        when (mapping.type) {
          TYPE_IGNORED -> Unit
          TYPE_MAPPED, TYPE_DISALLOWED_STD3_MAPPED -> {
            sink.write(mapping.mappedTo)
          }
    
          TYPE_DEVIATION, TYPE_DISALLOWED_STD3_VALID, TYPE_VALID -> {
            sink.writeUtf8CodePoint(codePoint)
          }
    
          TYPE_DISALLOWED -> {
            sink.writeUtf8CodePoint(codePoint)
            result = false
          }
        }
    
        return result
      }
    }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

              .post(
                object : RequestBody() {
                  override fun contentType() = null
    
                  override fun writeTo(sink: BufferedSink) {
                    for (i in 0..9) {
                      sink.writeByte(0)
                      sink.flush()
                      sleep(100)
                    }
                    fail("Expected connection to be closed")
                  }
                },
              )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt

        fail("")
      }
    
      override fun settings(
        clearPrevious: Boolean,
        settings: Settings,
      ) {
        fail("")
      }
    
      override fun ackSettings() {
        fail("")
      }
    
      override fun ping(
        ack: Boolean,
        payload1: Int,
        payload2: Int,
      ) {
        fail("")
      }
    
      override fun goAway(
        lastGoodStreamId: Int,
        errorCode: ErrorCode,
        debugData: ByteString,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt

          while (accumulatorBitCount >= 8) {
            accumulatorBitCount -= 8
            sink.writeByte((accumulator shr accumulatorBitCount).toInt())
          }
        }
    
        if (accumulatorBitCount > 0) {
          accumulator = accumulator shl (8 - accumulatorBitCount)
          accumulator = accumulator or (0xffL ushr accumulatorBitCount)
          sink.writeByte(accumulator.toInt())
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/ByteSourceTest.java

        TestByteSink sink = new TestByteSink();
    
        assertFalse(sink.wasStreamOpened() || sink.wasStreamClosed());
    
        assertEquals(bytes.length, source.copyTo(sink));
        assertTrue(source.wasStreamOpened() && source.wasStreamClosed());
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
    
        assertArrayEquals(bytes, sink.getBytes());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top