Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for flush (0.07 sec)

  1. src/bufio/example_test.go

    	fmt.Fprint(w, "Hello, ")
    	fmt.Fprint(w, "world!")
    	w.Flush() // Don't forget to flush!
    	// Output: Hello, world!
    }
    
    func ExampleWriter_AvailableBuffer() {
    	w := bufio.NewWriter(os.Stdout)
    	for _, i := range []int64{1, 2, 3, 4} {
    		b := w.AvailableBuffer()
    		b = strconv.AppendInt(b, i, 10)
    		b = append(b, ' ')
    		w.Write(b)
    	}
    	w.Flush()
    	// Output: 1 2 3 4
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. src/bufio/bufio_test.go

    	str := strings.Repeat("x", 1<<10)
    	bs := []byte(str)
    	for i := 0; i < b.N; i++ {
    		bw := NewWriter(io.Discard)
    		bw.Flush()
    		bw.WriteByte('a')
    		bw.Flush()
    		bw.WriteRune('B')
    		bw.Flush()
    		bw.Write(bs)
    		bw.Flush()
    		bw.WriteString(str)
    		bw.Flush()
    	}
    }
    
    func BenchmarkWriterFlush(b *testing.B) {
    	b.ReportAllocs()
    	bw := NewWriter(io.Discard)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java

                }
            }
    
            int pad = lastLength - buffer.length();
            lastLength = buffer.length();
            pad(buffer, pad);
            buffer.append('\r');
            out.print(buffer);
            out.flush();
            buffer.setLength(0);
        }
    
        private void pad(StringBuilder buffer, int spaces) {
            String block = "                                        ";
            while (spaces > 0) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/compare/sds/writer.go

    		} else {
    			fmt.Fprintf(tw, "%s\t%s\t%s\t%t\t%s\t%s\t%s\n",
    				s.Name, s.Type, s.State, s.Valid, s.SerialNumber, s.NotAfter, s.NotBefore)
    		}
    	}
    	return tw.Flush()
    }
    
    // printSecretItemsJSON prints secret in JSON format, and dumps the raw certificate data with the output
    func (w *sdsWriter) printSecretItemsJSON(secrets []SecretItem) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/io/LittleEndianDataOutputStream.java

      }
    
      // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior:
      // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream.
      // It should flush itself if necessary.
      @Override
      public void close() throws IOException {
        out.close();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 12:34:49 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataCache.java

                boolean resolveManagedVersions,
                ArtifactRepository localRepository,
                List<ArtifactRepository> remoteRepositories,
                ResolutionGroup result);
    
        void flush();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/table/writer.go

    		cells = append(cells, NewCell(name))
    	}
    	c.header = Row{Cells: cells}
    }
    
    func (c *ColoredTableWriter) AddRow(obj interface{}) {
    	c.rows = append(c.rows, c.addRowFunc(obj))
    }
    
    func (c *ColoredTableWriter) Flush() {
    	output := c.getTableOutput(c.rows)
    	if len(output) == 0 {
    		return
    	}
    	sep := getMaxWidths(output)
    	for _, row := range output {
    		for i, col := range row {
    			_, _ = fmt.Fprint(c.writer, col.String())
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 09:43:25 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/DefaultEncryptInvoker.java

                } else {
                    context.terminal.writer().println(e.getMessage());
                }
                return ERROR;
            } finally {
                context.terminal.writer().flush();
            }
        }
    
        protected int badGoalsErrorMessage(String message, LocalContext context) {
            context.terminal.writer().println(message);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/DefaultMavenMetadataCache.java

                    result.getArtifacts(),
                    result.getManagedVersions(),
                    result.getResolutionRepositories());
    
            cache.put(cacheKey, cacheRecord);
        }
    
        public void flush() {
            cache.clear();
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/ImmutableMapTest.java

        Collection<Integer> values = map.values();
    
        ByteArrayOutputStream bytes = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(bytes);
        oos.writeObject(map);
        oos.flush();
    
        int mapSize = bytes.size();
        oos.writeObject(keySet);
        oos.writeObject(values);
        oos.close();
    
        int finalSize = bytes.size();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 41.1K bytes
    - Viewed (0)
Back to top