Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 242 for reader_r (0.04 seconds)

  1. compat/maven-toolchain-builder/src/test/java/org/apache/maven/toolchain/merge/MavenToolchainMergerTest.java

    import static org.junit.jupiter.api.Assertions.assertEquals;
    
    class MavenToolchainMergerTest {
        private MavenToolchainMerger merger = new MavenToolchainMerger();
    
        private DefaultToolchainsReader reader = new DefaultToolchainsReader();
    
        @Test
        void testMergeNulls() {
            merger.merge(null, null, null);
    
            PersistedToolchains pt = new PersistedToolchains();
            merger.merge(pt, null, null);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 6K bytes
    - Click Count (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/builtin/BuiltinShellCommandRegistryFactory.java

    import org.jline.console.CommandMethods;
    import org.jline.console.CommandRegistry;
    import org.jline.console.impl.JlineCommandRegistry;
    import org.jline.reader.Completer;
    import org.jline.reader.impl.completer.ArgumentCompleter;
    import org.jline.reader.impl.completer.StringsCompleter;
    
    import static java.util.Objects.requireNonNull;
    
    @Named("builtin")
    @Singleton
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Jun 07 06:22:47 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  3. internal/etag/etag_test.go

    	},
    }
    
    func TestReader(t *testing.T) {
    	for i, test := range readerTests {
    		reader := NewReader(t.Context(), strings.NewReader(test.Content), test.ETag, nil)
    		if _, err := io.Copy(io.Discard, reader); err != nil {
    			t.Fatalf("Test %d: read failed: %v", i, err)
    		}
    		if ETag := reader.ETag(); !Equal(ETag, test.ETag) {
    			t.Fatalf("Test %d: ETag mismatch: got %q - want %q", i, ETag, test.ETag)
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  4. docs/debugging/inspect/main.go

    			} else {
    				break
    			}
    			n++
    		}
    
    		// Prompt for decryption key if no --key or --private-key are provided
    		if len(privateKeys) == 0 && !*stdin {
    			reader := bufio.NewReader(os.Stdin)
    			fmt.Print("Enter Decryption Key: ")
    
    			text, _ := reader.ReadString('\n')
    			// convert CRLF to LF
    			*keyHex = strings.ReplaceAll(text, "\n", "")
    			*keyHex = strings.TrimSpace(*keyHex)
    		}
    	}
    
    	var inputs []string
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 17 17:09:42 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  5. benchmarks/src/main/java/org/elasticsearch/benchmark/script/ScriptScoreBenchmark.java

                }
                w.commit();
            }
            reader = DirectoryReader.open(directory);
        }
    
        @Benchmark
        public TopDocs benchmark() throws IOException {
            TopDocs topDocs = new IndexSearcher(reader).search(scriptScoreQuery(factory), 10);
            if (topDocs.scoreDocs[0].score != 1_000_000) {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Mon Sep 20 13:45:50 GMT 2021
    - 8.1K bytes
    - Click Count (0)
  6. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

          // Replace the body with a stripped one so the callbacks can't see real data.
          val response = response.stripBody()
    
          val reader = ServerSentEventReader(body.source(), this)
          try {
            if (!canceled) {
              listener.onOpen(this, response)
              while (!canceled && reader.processNextEvent()) {
              }
            }
          } catch (e: Exception) {
            val exception =
              when {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Oct 03 07:51:20 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/io/SourceSinkFactories.java

        }
    
        @Override
        public String getSinkContents() throws IOException {
          File file = getFile();
          Reader reader = new InputStreamReader(new FileInputStream(file), UTF_8);
          StringBuilder builder = new StringBuilder();
          CharBuffer buffer = CharBuffer.allocate(100);
          while (reader.read(buffer) != -1) {
            Java8Compatibility.flip(buffer);
            builder.append(buffer);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  8. src/main/java/jcifs/netbios/Lmhosts.java

     */
    
    package jcifs.netbios;
    
    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.Reader;
    import java.util.HashMap;
    import java.util.Map;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSContext;
    import jcifs.smb.SmbFileInputStream;
    
    /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/app/web/admin/badword/AdminBadwordAction.java

            verifyToken(this::asUploadHtml);
            CommonPoolUtil.execute(() -> {
                try (Reader reader = new BufferedReader(new InputStreamReader(form.badWordFile.getInputStream(), getCsvEncoding()))) {
                    badWordService.importCsv(reader);
                    suggestHelper.storeAllBadWords(false);
                } catch (final Exception e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Jan 23 23:57:26 GMT 2026
    - 18K bytes
    - Click Count (0)
  10. api/go1.25.txt

    pkg crypto, func SignMessage(Signer, io.Reader, []uint8, SignerOpts) ([]uint8, error) #63405
    pkg crypto, type MessageSigner interface { Public, Sign, SignMessage } #63405
    pkg crypto, type MessageSigner interface, Public() PublicKey #63405
    pkg crypto, type MessageSigner interface, Sign(io.Reader, []uint8, SignerOpts) ([]uint8, error) #63405
    pkg crypto, type MessageSigner interface, SignMessage(io.Reader, []uint8, SignerOpts) ([]uint8, error) #63405
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 02 16:09:57 GMT 2025
    - 6.8K bytes
    - Click Count (0)
Back to Top