Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 306 for Exiter (0.04 sec)

  1. android/guava/src/com/google/common/io/CharSource.java

        checkNotNull(sink);
    
        Closer closer = Closer.create();
        try {
          Reader reader = closer.register(openStream());
          Writer writer = closer.register(sink.openStream());
          return CharStreams.copy(reader, writer);
        } catch (Throwable e) {
          throw closer.rethrow(e);
        } finally {
          closer.close();
        }
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/io/CharSource.java

        checkNotNull(sink);
    
        Closer closer = Closer.create();
        try {
          Reader reader = closer.register(openStream());
          Writer writer = closer.register(sink.openStream());
          return CharStreams.copy(reader, writer);
        } catch (Throwable e) {
          throw closer.rethrow(e);
        } finally {
          closer.close();
        }
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

    import org.codelibs.fess.suggest.index.contents.querylog.QueryLogReader;
    import org.codelibs.fess.suggest.index.writer.SuggestIndexWriter;
    import org.codelibs.fess.suggest.index.writer.SuggestWriter;
    import org.codelibs.fess.suggest.index.writer.SuggestWriterResult;
    import org.codelibs.fess.suggest.normalizer.Normalizer;
    import org.codelibs.fess.suggest.settings.SuggestSettings;
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/api/admin/badword/ApiAdminBadwordAction.java

                final Path tempFile = ComponentUtil.getSystemHelper().createTempFile("fess-badword-", ".csv").toPath();
                try {
                    try (Writer writer = new BufferedWriter(new OutputStreamWriter(Files.newOutputStream(tempFile), getCsvEncoding()))) {
                        badWordService.exportCsv(writer);
                    } catch (final Exception e) {
                        logger.warn("Failed to process a request.", e);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        Thread waiter =
            new Thread() {
              @Override
              public void run() {
                try {
                  service.awaitTermination(1, DAYS);
                } catch (InterruptedException e) {
                  return;
                }
              }
            };
        waiter.start();
        awaitTimedWaiting(waiter);
        service.shutdown();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  6. compat/maven-compat/src/test/java/org/apache/maven/artifact/AbstractArtifactComponentTestCase.java

            if (!artifactFile.getParentFile().exists()) {
                artifactFile.getParentFile().mkdirs();
            }
            try (Writer writer = new OutputStreamWriter(new FileOutputStream(artifactFile), StandardCharsets.ISO_8859_1)) {
                writer.write(artifact.getId());
            }
    
            MessageDigest md = MessageDigest.getInstance("MD5");
            md.update(artifact.getId().getBytes());
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Mar 21 04:56:21 UTC 2025
    - 13.8K bytes
    - Viewed (0)
  7. cmd/bitrot-streaming.go

    // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation.
    // The output is written to the supplied writer w.
    func newStreamingBitrotWriterBuffer(w io.Writer, algo BitrotAlgorithm, shardSize int64) io.Writer {
    	return &streamingBitrotWriter{iow: ioutil.NopCloser(w), h: algo.New(), shardSize: shardSize, canClose: nil, closeWithErr: func(err error) {}}
    }
    
    // Returns streaming bitrot writer implementation.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  8. cmd/post-policy_test.go

    	if !corruptedMultipart {
    		var writer io.Writer
    		var err error
    		if noFilename {
    			writer, err = w.CreateFormField("file")
    		} else {
    			writer, err = w.CreateFormFile("file", "upload.txt")
    		}
    		if err != nil {
    			// return nil, err
    			return nil, err
    		}
    		writer.Write(objData)
    		// Close before creating the new request.
    		w.Close()
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.6K bytes
    - Viewed (0)
  9. src/bufio/example_test.go

    func ExampleWriter_ReadFrom() {
    	var buf bytes.Buffer
    	writer := bufio.NewWriter(&buf)
    
    	data := "Hello, world!\nThis is a ReadFrom example."
    	reader := strings.NewReader(data)
    
    	n, err := writer.ReadFrom(reader)
    	if err != nil {
    		fmt.Println("ReadFrom Error:", err)
    		return
    	}
    
    	if err = writer.Flush(); err != nil {
    		fmt.Println("Flush Error:", err)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt

        val newMaxFrameSize = 16777215
        val writer = Http2Writer(Buffer(), true)
        writer.applyAndAckSettings(Settings().set(Settings.MAX_FRAME_SIZE, newMaxFrameSize))
        assertThat(writer.maxDataLength()).isEqualTo(newMaxFrameSize)
        writer.frameHeader(0, newMaxFrameSize, Http2.TYPE_DATA, FLAG_NONE)
      }
    
      @Test fun streamIdHasReservedBit() {
        val writer = Http2Writer(Buffer(), true)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 28.1K bytes
    - Viewed (0)
Back to top