Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 951 for writer (0.05 seconds)

  1. cmd/bitrot.go

    func closeBitrotReaders(rs []io.ReaderAt) {
    	for _, r := range rs {
    		if r != nil {
    			if br, ok := r.(io.Closer); ok {
    				br.Close()
    			}
    		}
    	}
    }
    
    // Close all the writers.
    func closeBitrotWriters(ws []io.Writer) []error {
    	errs := make([]error, len(ws))
    	for i, w := range ws {
    		if w == nil {
    			errs[i] = errDiskNotFound
    			continue
    		}
    		if bw, ok := w.(io.Closer); ok {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/io/BaseEncodingTest.java

          throws IOException {
        StringWriter writer = new StringWriter();
        try (OutputStream encodingStream = encoding.encodingStream(writer)) {
          encodingStream.write(decoded.getBytes(UTF_8));
        }
        assertThat(writer.toString()).isEqualTo(encoded);
      }
    
      @GwtIncompatible // Reader
      private static void testStreamingDecodes(BaseEncoding encoding, String encoded, String decoded)
          throws IOException {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 24.7K bytes
    - Click Count (0)
  3. 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)
  4. android/guava/src/com/google/common/io/CharSource.java

        }
    
        @Override
        public long copyTo(CharSink sink) throws IOException {
          checkNotNull(sink);
          Closer closer = Closer.create();
          try {
            Writer writer = closer.register(sink.openStream());
            writer.write((String) seq);
            return seq.length();
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  5. guava/src/com/google/common/io/CharSource.java

        }
    
        @Override
        public long copyTo(CharSink sink) throws IOException {
          checkNotNull(sink);
          Closer closer = Closer.create();
          try {
            Writer writer = closer.register(sink.openStream());
            writer.write((String) seq);
            return seq.length();
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.3K bytes
    - Click Count (0)
  6. logger/logger.go

    	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
    	IgnoreRecordNotFoundError bool
    	ParameterizedQueries      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)
  7. 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)
  8. cmd/erasure-decode_test.go

    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(test.data), writeAlgorithm, erasure.ShardSize())
    		}
    		n, err := erasure.Encode(t.Context(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 21K bytes
    - Click Count (0)
  9. src/bufio/example_test.go

    		b = append(b, ' ')
    		w.Write(b)
    	}
    	w.Flush()
    	// Output: 1 2 3 4
    }
    
    // ExampleWriter_ReadFrom demonstrates how to use the ReadFrom method of Writer.
    func ExampleWriter_ReadFrom() {
    	var buf bytes.Buffer
    	writer := bufio.NewWriter(&buf)
    
    	data := "Hello, world!\nThis is a ReadFrom example."
    	reader := strings.NewReader(data)
    
    	n, err := writer.ReadFrom(reader)
    	if err != nil {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Nov 01 21:52:12 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  10. guava/src/com/google/common/io/BaseEncoding.java

       * {@code Writer}. When the returned {@code OutputStream} is closed, so is the backing {@code
       * Writer}.
       */
      @J2ktIncompatible
      @GwtIncompatible // Writer,OutputStream
      public abstract OutputStream encodingStream(Writer writer);
    
      /**
       * Returns a {@code ByteSink} that writes base-encoded bytes to the specified {@code CharSink}.
       */
      @J2ktIncompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Oct 06 14:51:47 GMT 2025
    - 41.7K bytes
    - Click Count (0)
Back to Top