- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 272 for awaiter (0.05 sec)
-
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) -
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) -
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) -
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 boolRegistered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun Jan 12 10:19:28 UTC 2025 - 6.3K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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)