- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,840 for Primer (0.1 sec)
-
internal/s3select/message.go
bytesReturned := atomic.LoadInt64(&writer.bytesReturned) if !writer.write(newStatsMessage(writer.finBytesScanned, writer.finBytesProcessed, bytesReturned)) { break } writer.write(endMessage) } else { for payload.Len() > 0 { copiedLen := copy(writer.payloadBuffer[writer.payloadBufferIndex:], payload.Bytes()) writer.payloadBufferIndex += copiedLen payload.Next(copiedLen)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/report/IncompatibleTypeReferenceReporter.java
writer.print(description); writer.print(")"); } writer.println(" is invalid due to incompatible types."); writer.print("This element was created by "); writer.print(creator); writer.print(" and can be "); writer.print(writable ? "mutated" : "read"); writer.println(" as the following types:"); boolean first = true;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 3.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/verification/serializer/DependencyVerificationsXmlWriter.java
writer.startElement(VERIFY_SIGNATURES); writer.write(String.valueOf(configuration.isVerifySignatures())); writer.endElement(); } private void writeVerifyMetadata(DependencyVerificationConfiguration configuration) throws IOException { writer.startElement(VERIFY_METADATA); writer.write(String.valueOf(configuration.isVerifyMetadata()));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 01 13:40:00 UTC 2024 - 15.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/process/ArgWriter.java
private static final Pattern WHITESPACE_OR_HASH = Pattern.compile("\\s|#"); private final PrintWriter writer; private final boolean backslashEscape; private final Pattern quotablePattern; private ArgWriter(PrintWriter writer, boolean backslashEscape, Pattern quotablePattern) { this.writer = writer; this.backslashEscape = backslashEscape; this.quotablePattern = quotablePattern; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 10:14:33 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/junit/result/JUnitXmlResultWriter.java
writer.endCDATA(); writer.endElement(); } if (options.includeSystemErrLog && outputProvider.has(TestOutputEvent.Destination.StdErr)) { writer.startElement("system-err"); writer.startCDATA(); outputProvider.write(TestOutputEvent.Destination.StdErr, writer); writer.endCDATA(); writer.endElement();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 25 18:49:57 UTC 2024 - 18.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSink.java
* @since 15.0 (in 14.0 with return type {@link BufferedWriter}) */ public Writer openBufferedStream() throws IOException { Writer writer = openStream(); return (writer instanceof BufferedWriter) ? (BufferedWriter) writer : new BufferedWriter(writer); } /** * Writes the given character sequence to this sink. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/volume/csi/csi_drivers_store_test.go
store := &csi.DriversStore{} someDriver := csi.Driver{} expectAbsent(t, store, "does-not-exist") store.Set("some-driver", someDriver) expectPresent(t, store, "some-driver", someDriver) store.Delete("some-driver") expectAbsent(t, store, "some-driver") store.Set("some-driver", someDriver) store.Clear() expectAbsent(t, store, "some-driver") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 25 12:23:15 UTC 2019 - 1.5K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
}, }, { name: "PersistentVolume with driver info", specName: "pv2", driver: "simple-driver", volName: "vol2", specFunc: func(specName, driver, volName string) *volume.Spec { return volume.NewSpecFromPersistentVolume(makeTestPV(specName, 20, driver, volName), false) }, podFunc: func() *api.Pod { podUID := types.UID(fmt.Sprintf("%08X", rand.Uint64()))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
src/compress/gzip/gzip.go
} // NewWriter returns a new [Writer]. // Writes to the returned writer are compressed and written to w. // // It is the caller's responsibility to call Close on the [Writer] when done. // Writes may be buffered and not flushed until Close. // // Callers that wish to set the fields in Writer.Header must do so before // the first call to Write, Flush, or Close. func NewWriter(w io.Writer) *Writer {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/volume/csi/csi_drivers_store.go
// This method is protected by a mutex. func (s *DriversStore) Get(driverName string) (Driver, bool) { s.RLock() defer s.RUnlock() driver, ok := s.store[driverName] return driver, ok } // Set lets you save a CSI Driver to the list and give it a specific name. // This method is protected by a mutex. func (s *DriversStore) Set(driverName string, driver Driver) { s.Lock() defer s.Unlock() if s.store == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 1.8K bytes - Viewed (0)