- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 276 for awaiter (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 boolCreated: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Jan 12 10:19:28 GMT 2025 - 6.3K bytes - Click Count (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();Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Oct 27 13:24:03 GMT 2025 - 6.7K bytes - Click Count (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; } /**Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sun Nov 23 12:19:14 GMT 2025 - 30.8K bytes - Click Count (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 =Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 10.1K bytes - Click Count (0) -
clause/clause.go
// ClauseBuilder clause builder, allows to customize how to build clause type ClauseBuilder func(Clause, Builder) type Writer interface { WriteByte(byte) error WriteString(string) (int, error) } // Builder builder interface type Builder interface { Writer WriteQuoted(field interface{}) AddVar(Writer, ...interface{}) AddError(error) error } // Clause type Clause struct { Name string // WHERE
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Thu Feb 02 09:15:08 GMT 2023 - 1.7K bytes - Click Count (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 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.1K bytes - Click Count (0) -
internal/s3select/select.go
// make a buffer with a reasonable capacity. return bytes.NewBuffer(make([]byte, 0, maxRecordSize)) }, } var bufioWriterPool = bpool.Pool[*bufio.Writer]{ New: func() *bufio.Writer { // io.Discard is just used to create the writer. Actual destination // writer is set later by Reset() before using it. return bufio.NewWriter(xioutil.Discard) }, } // UnmarshalXML - decodes XML data.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 21.2K bytes - Click Count (0) -
cmd/erasure-encode.go
} // Encode reads from the reader, erasure-encodes the data and writes to the writers. func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := &multiWriter{ writers: writers, writeQuorum: quorum, errs: make([]error, len(writers)), } for { var blocks [][]byte n, err := io.ReadFull(src, buf)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed May 15 00:11:04 GMT 2024 - 2.9K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/InteractiveGoalSupport.java
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Dec 11 09:13:06 GMT 2024 - 2.1K bytes - Click Count (0) -
internal/config/subnet/subnet.go
} var body bytes.Buffer writer := multipart.NewWriter(&body) part, e := writer.CreateFormFile("file", filename) if e != nil { return "", e } if _, e = part.Write(payload); e != nil { return "", e } writer.Close() r, e := http.NewRequest(http.MethodPost, reqURL, &body) if e != nil { return "", e } r.Header.Add("Content-Type", writer.FormDataContentType()) return c.submitPost(r)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.9K bytes - Click Count (0)