- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 735 for readers (0.23 sec)
-
maven-core/src/main/java/org/apache/maven/resolver/MavenChainedWorkspaceReader.java
protected List<WorkspaceReader> readers; protected WorkspaceRepository repository; /** * Creates a new workspace reader by chaining the specified readers. * * @param readers The readers to chain must not be {@code null}. */ public MavenChainedWorkspaceReader(WorkspaceReader... readers) { setReaders(Arrays.asList(readers)); } @Override
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/erasure-decode.go
} // Heal reads from readers, reconstruct shards and writes the data to the writers. func (e Erasure) Heal(ctx context.Context, writers []io.Writer, readers []io.ReaderAt, totalLength int64, prefer []bool) (derr error) { if len(writers) != e.parityBlocks+e.dataBlocks { return errInvalidArgument } reader := newParallelReader(readers, e, 0, totalLength) if len(readers) == len(prefer) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/metacache-set.go
// not a storage error. return nil } readers := make([]*metacacheReader, len(disks)) defer func() { for _, r := range readers { r.Close() } }() for i := range disks { r, w := io.Pipe() // Make sure we close the pipe so blocked writes doesn't stay around. defer r.CloseWithError(context.Canceled) readers[i] = newMetacacheReader(r) d := disks[i]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/erasure-heal_test.go
closeBitrotWriters(writers) if err != nil { t.Fatalf("Test %d: failed to create random test data: %v", i, err) } readers := make([]io.ReaderAt, len(disks)) for i, disk := range disks { shardFilesize := erasure.ShardFileSize(test.size) readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
return nil, err } readers = append(readers, dirReaders...) } else { if !isValidFile(f) { fmt.Fprintf(cmd.ErrOrStderr(), "Skipping file %v, recognized file extensions are: %v\n", f, fileExtensions) continue } rs, err := gatherFile(f) if err != nil { return nil, err } readers = append(readers, rs) } } return readers, nil }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/resolver/RepositorySystemSessionFactory.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Jan 19 11:00:28 GMT 2024 - 1.7K bytes - Viewed (0) -
src/archive/zip/writer.go
// flag bit is set. However, there are several problems: // // * Many ZIP readers still do not support UTF-8. // * If the UTF-8 flag is cleared, several readers simply interpret the // name and comment fields as whatever the local system encoding is. // // In order to avoid breaking readers without UTF-8 support, // we avoid setting the UTF-8 flag if the strings are CP-437 compatible.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java
final Iterator<ImageReader> readers = ImageIO.getImageReaders(input); if (readers.hasNext()) { final ImageReader reader = readers.next(); try { reader.setInput(input); final ImageReadParam param = reader.getDefaultReadParam(); final int width = reader.getWidth(0); final int height = reader.getHeight(0);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/package-info.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ /** * Utility methods and classes for I/O; for example input streams, output streams, readers, writers, * and files. * * <p>At the core of this package are the Source/Sink types: {@link ByteSource ByteSource}, {@link * CharSource CharSource}, {@link ByteSink ByteSink} and {@link CharSink CharSink}. They are
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Jun 23 19:57:03 GMT 2023 - 1.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponseBody.kt
import okhttp3.ExperimentalOkHttpApi import okio.BufferedSink /** * The body of a [MockResponse]. * * Unlike [okhttp3.ResponseBody], this interface is designed to be implemented by writers and not * called by readers. */ @ExperimentalOkHttpApi interface MockResponseBody { /** The length of this response in bytes, or -1 if unknown. */ val contentLength: Long @Throws(IOException::class) fun writeTo(sink: BufferedSink)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.1K bytes - Viewed (0)