Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 276 for awaiter (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Jan 12 10:19:28 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/InteractiveGoalSupport.java

            if (!context.interactive) {
                context.terminal.writer().println("This tool works only in interactive mode!");
                context.terminal
                        .writer()
                        .println("Tool purpose is to configure password management on developer workstations.");
                context.terminal
                        .writer()
                        .println(
    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)
  10. 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)
Back to Top