Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,377 for Tout (0.04 sec)

  1. mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

          )
        stream.writeHeaders(
          responseHeaders = responseHeaders,
          outFinished = false,
          flushHeaders = false,
        )
        val out = stream.getSink().buffer()
        out.writeUtf8("Not found: $path")
        out.close()
      }
    
      private fun serveDirectory(
        stream: Http2Stream,
        files: Array<File>,
      ) {
        val responseHeaders =
          listOf(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. docs/distributed/decom.sh

    out=$(diff -qpruN expanded_ns.txt decommissioned_ns.txt)
    ret=$?
    if [ $ret -ne 0 ]; then
    	echo "BUG: expected no missing entries after decommission: $out"
    	exit 1
    fi
    
    out=$(diff -qpruN expanded_ns_versions.txt decommissioned_ns_versions.txt)
    ret=$?
    if [ $ret -ne 0 ]; then
    	echo "BUG: expected no missing entries after decommission: $out"
    	exit 1
    fi
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  3. .teamcity/.mvn/wrapper/MavenWrapperDownloader.java

                }
            }
            System.out.println("- Downloading to: " + outputFile.getAbsolutePath());
            try {
                downloadFileFromURL(url, outputFile);
                System.out.println("Done");
                System.exit(0);
            } catch (Throwable e) {
                System.out.println("- Error downloading");
                e.printStackTrace();
                System.exit(1);
            }
        }
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Feb 26 01:48:39 UTC 2020
    - 4.8K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/RewriteResponseCacheControl.java

            // can be read from the cache.
            System.out.println("Force cache: true");
            clientForCall = client.newBuilder()
                .addNetworkInterceptor(REWRITE_CACHE_CONTROL_INTERCEPTOR)
                .build();
          } else {
            System.out.println("Force cache: false");
            clientForCall = client;
          }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 2.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/CountingOutputStream.java

       *
       * @param out the output stream to be wrapped
       */
      public CountingOutputStream(OutputStream out) {
        super(checkNotNull(out));
      }
    
      /** Returns the number of bytes written. */
      public long getCount() {
        return count;
      }
    
      @Override
      public void write(byte[] b, int off, int len) throws IOException {
        out.write(b, off, len);
        count += len;
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/ByteSinkTester.java

      }
    
      public void testOpenStream() throws IOException {
        OutputStream out = sink.openStream();
        try {
          ByteStreams.copy(new ByteArrayInputStream(data), out);
        } finally {
          out.close();
        }
    
        assertContainsExpectedBytes();
      }
    
      public void testOpenBufferedStream() throws IOException {
        OutputStream out = sink.openBufferedStream();
        try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/ByteSinkTester.java

      }
    
      public void testOpenStream() throws IOException {
        OutputStream out = sink.openStream();
        try {
          ByteStreams.copy(new ByteArrayInputStream(data), out);
        } finally {
          out.close();
        }
    
        assertContainsExpectedBytes();
      }
    
      public void testOpenBufferedStream() throws IOException {
        OutputStream out = sink.openBufferedStream();
        try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/base/CaseFormat.java

        // deal with camel conversion
        StringBuilder out = null;
        int i = 0;
        int j = -1;
        while ((j = wordBoundary.indexIn(s, ++j)) != -1) {
          if (i == 0) {
            // include some extra space for separators
            out = new StringBuilder(s.length() + 4 * format.wordSeparator.length());
            out.append(format.normalizeFirstWord(s.substring(i, j)));
          } else {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 19 20:20:14 UTC 2022
    - 6.3K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/TestOutputStream.java

      private final ImmutableSet<TestOption> options;
      private boolean closed;
    
      public TestOutputStream(OutputStream out, TestOption... options) throws IOException {
        this(out, Arrays.asList(options));
      }
    
      public TestOutputStream(OutputStream out, Iterable<TestOption> options) throws IOException {
        super(checkNotNull(out));
        this.options = ImmutableSet.copyOf(options);
        throwIf(OPEN_THROWS);
      }
    
      public boolean closed() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.2K bytes
    - Viewed (0)
  10. samples/slack/src/main/java/okhttp3/slack/RtmSession.java

      @Override public synchronized void onOpen(WebSocket webSocket, Response response) {
        System.out.println("onOpen: " + response);
      }
    
      // TOOD(jwilson): decode incoming messages and dispatch them somewhere.
      @Override public void onMessage(WebSocket webSocket, String text) {
        System.out.println("onMessage: " + text);
      }
    
      @Override public void onClosing(WebSocket webSocket, int code, String reason) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Nov 19 20:16:58 UTC 2016
    - 2.4K bytes
    - Viewed (0)
Back to top