Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 245 for flush (0.12 sec)

  1. okhttp/src/test/java/okhttp3/CallTest.kt

              return null
            }
    
            override fun writeTo(sink: BufferedSink) {
              sink.writeUtf8("abc")
              sink.flush()
              makeFailingCall()
              sink.writeUtf8("def")
              sink.flush()
            }
          }
        val call =
          client.newCall(
            Request(
              url = server.url("/"),
              body = requestBody,
            ),
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  2. okhttp-android/src/main/baseline-prof.txt

    HSPLokhttp3/internal/http2/Http2Writer;->close()V
    HSPLokhttp3/internal/http2/Http2Writer;->data(ZILokio/Buffer;I)V
    HSPLokhttp3/internal/http2/Http2Writer;->flush()V
    HSPLokhttp3/internal/http2/Http2Writer;->frameHeader(IIII)V
    HSPLokhttp3/internal/http2/Http2Writer;->goAway(ILokhttp3/internal/http2/ErrorCode;[B)V
    HSPLokhttp3/internal/http2/Http2Writer;->headers(ZILjava/util/List;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

                // do not pass directly the terminal writer
                return msg -> {
                    PrintWriter pw = context.terminal.writer();
                    pw.println(msg);
                    pw.flush();
                };
            }
        }
    
        protected void activateLogging(C context) throws Exception {
            R invokerRequest = context.invokerRequest;
            Options mavenOptions = invokerRequest.options();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      <T> T serialClone(T o) {
        try {
          ByteArrayOutputStream bos = new ByteArrayOutputStream();
          ObjectOutputStream oos = new ObjectOutputStream(bos);
          oos.writeObject(o);
          oos.flush();
          oos.close();
          ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(bos.toByteArray()));
          T clone = (T) ois.readObject();
          assertSame(o.getClass(), clone.getClass());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/ImmutableMapTest.java

        Collection<Integer> values = map.values();
    
        ByteArrayOutputStream bytes = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(bytes);
        oos.writeObject(map);
        oos.flush();
    
        int mapSize = bytes.size();
        oos.writeObject(keySet);
        oos.writeObject(values);
        oos.close();
    
        int finalSize = bytes.size();
    
        assertThat(finalSize - mapSize).isLessThan(100);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 36.6K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

                            ".out", SystemUtils.getJavaIoTmpDir())) {
                        CopyUtil.copy(responseBodyStream, dfos);
                        dfos.flush();
    
                        if (dfos.isInMemory()) {
                            responseData.setResponseBody(dfos.getData());
                            contentLength = dfos.getData().length;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 09 09:29:26 UTC 2024
    - 41K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        testFlushAfterStreamTransmitted(TransferKind.END_OF_STREAM)
      }
    
      /**
       * We explicitly permit apps to close the upload stream even after it has been transmitted.  We
       * also permit flush so that buffered streams can do a no-op flush when they are closed.
       * http://b/3038470
       */
      private fun testFlushAfterStreamTransmitted(transferKind: TransferKind) {
        server.enqueue(
          MockResponse(body = "abc"),
        )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      <T> T serialClone(T o) {
        try {
          ByteArrayOutputStream bos = new ByteArrayOutputStream();
          ObjectOutputStream oos = new ObjectOutputStream(bos);
          oos.writeObject(o);
          oos.flush();
          oos.close();
          ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(bos.toByteArray()));
          T clone = (T) ois.readObject();
          assertSame(o.getClass(), clone.getClass());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  9. cmd/data-usage-cache.go

    		zstd.WithEncoderConcurrency(2))
    	if err != nil {
    		return err
    	}
    	mEnc := msgp.NewWriter(enc)
    	err = d.EncodeMsg(mEnc)
    	if err != nil {
    		return err
    	}
    	err = mEnc.Flush()
    	if err != nil {
    		return err
    	}
    	err = enc.Close()
    	if err != nil {
    		return err
    	}
    	return nil
    }
    
    // deserialize the supplied byte slice into the cache.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  10. src/cmd/api/main_test.go

    		for cname := range cmap {
    			f2 := fmt.Sprintf("%s (%s)%s", f[:comma], cname, f[comma:])
    			features = append(features, f2)
    		}
    	}
    
    	bw := bufio.NewWriter(os.Stdout)
    	defer bw.Flush()
    
    	var required []string
    	for _, file := range checkFiles {
    		required = append(required, fileFeatures(file, needApproval(file))...)
    	}
    	for _, file := range nextFiles {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 31.4K bytes
    - Viewed (0)
Back to top