Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 272 for awaiter (0.04 sec)

  1. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        Appendable plainAppendable = new StringBuilder();
        Writer result = CharStreams.asWriter(plainAppendable);
        assertNotSame(plainAppendable, result);
        assertThat(result).isNotNull();
    
        // A Writer should not be wrapped
        Appendable secretlyAWriter = new StringWriter();
        result = CharStreams.asWriter(secretlyAWriter);
        assertSame(secretlyAWriter, result);
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/io/CharStreamsTest.java

        Appendable plainAppendable = new StringBuilder();
        Writer result = CharStreams.asWriter(plainAppendable);
        assertNotSame(plainAppendable, result);
        assertThat(result).isNotNull();
    
        // A Writer should not be wrapped
        Appendable secretlyAWriter = new StringWriter();
        result = CharStreams.asWriter(secretlyAWriter);
        assertSame(secretlyAWriter, result);
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/CharSourceTest.java

        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertTrue(source.wasStreamClosed());
        assertEquals(STRING, writer.toString());
      }
    
      public void testLines() throws IOException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  4. logger/logger.go

    const (
    	// Silent silent log level
    	Silent LogLevel = iota + 1
    	// Error error log level
    	Error
    	// Warn warn log level
    	Warn
    	// Info info log level
    	Info
    )
    
    // Writer log writer interface
    type Writer interface {
    	Printf(string, ...interface{})
    }
    
    // Config logger config
    type Config struct {
    	SlowThreshold             time.Duration
    	Colorful                  bool
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun Jan 12 10:19:28 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  5. compat/maven-embedder/src/main/java/org/apache/maven/cli/internal/extension/model/io/xpp3/CoreExtensionsXpp3Writer.java

            this.fileComment = fileComment;
        } // -- void setFileComment( String )
    
        /**
         * Method write.
         *
         * @param writer a writer object.
         * @param coreExtensions a coreExtensions object.
         * @throws IOException IOException if any.
         */
        public void write(Writer writer, CoreExtensions coreExtensions) throws IOException {
            XmlSerializer serializer = new MXSerializer();
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Mon Oct 27 13:24:03 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  6. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsWriter.java

        void write(File output, Map<String, Object> options, Settings settings) throws IOException;
    
        /**
         * Writes the supplied settings to the specified character writer. The writer will be automatically closed before
         * the method returns.
         *
         * @param output The writer to serialize the settings to, must not be {@code null}.
         * @param options The options to use for serialization, may be {@code null} to use the default values.
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *   <li>calls {@link ExecutorService#shutdown()}, disabling acceptance of new submitted tasks.
       *   <li>awaits executor service termination for half of the specified timeout.
       *   <li>if the timeout expires, it calls {@link ExecutorService#shutdownNow()}, cancelling
       *       pending tasks and interrupting running tasks.
       *   <li>awaits executor service termination for the other half of the specified timeout.
       * </ol>
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/TikaExtractor.java

        protected interface ContentWriter {
            /**
             * Accepts a writer.
             * @param writer A writer.
             * @throws IOException if an I/O error occurs.
             * @throws TikaException if a Tika exception occurs.
             * @throws SAXException if a SAX exception occurs.
             */
            void accept(Writer writer) throws IOException, TikaException, SAXException;
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 30.8K bytes
    - Viewed (0)
  9. internal/s3select/csv/record.go

    	other.csvRecord = append(other.csvRecord, r.csvRecord...)
    	return other
    }
    
    // WriteCSV - encodes to CSV data.
    func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error {
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.AlwaysQuote = opts.AlwaysQuote
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(r.csvRecord); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/ShellInvoker.java

                    ░▒▓█▓▒░░▒▓█▓▒░░▒▓█▓▒░   ░▒▓██▓▒░   ░▒▓█▓▒░░▒▓█▓▒░░▒▓███████▓▒░ ░▒▓█▓▒░░▒▓█▓▒░""";
            context.writer.accept(banner);
            if (!context.options().showVersion().orElse(false)) {
                context.writer.accept(CLIReportingUtils.showVersionMinimal());
            }
            context.writer.accept("");
    
            try (holder) {
                SimpleSystemRegistryImpl systemRegistry =
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Oct 16 06:12:36 UTC 2025
    - 10.1K bytes
    - Viewed (0)
Back to top