- Sort Score
- Num 10 results
- Language All
Results 271 - 280 of 302 for awaiter (0.06 seconds)
-
src/archive/zip/reader_test.go
b := bytes.NewBuffer(nil) w := NewWriter(b) for i := 0; i < 5; i++ { _, err := w.Create("") if err != nil { t.Fatalf("Writer.Create failed: %s", err) } } if err := w.Close(); err != nil { t.Fatalf("Writer.Close failed: %s", err) } r, err := NewReader(bytes.NewReader(b.Bytes()), int64(b.Len())) if err != nil { t.Fatalf("NewReader failed: %s", err) }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Oct 17 20:10:27 GMT 2025 - 56.5K bytes - Click Count (0) -
cmd/admin-handlers-users.go
sys: nil, }) if zerr != nil { adminLogIf(ctx, zerr) return nil } header.Method = zip.Deflate zwriter, zerr := zipWriter.CreateHeader(header) if zerr != nil { adminLogIf(ctx, zerr) return nil } if _, err := io.Copy(zwriter, r); err != nil { adminLogIf(ctx, err) } return nil } for _, f := range iamExportFiles {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 90.6K bytes - Click Count (0) -
lib/wasm/wasm_exec.js
throw new Error("total length of command line and environment variables exceeds limit"); } this._inst.exports.run(argc, argv); if (this.exited) { this._resolveExitPromise(); } await this._exitPromise; } _resume() { if (this.exited) { throw new Error("Go program has already exited"); } this._inst.exports.resume(); if (this.exited) {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Sun Dec 08 15:34:47 GMT 2024 - 16.6K bytes - Click Count (0) -
cmd/object-api-utils_test.go
t.Fatalf("Initializing config.json failed") } objectName := `\../.minio.sys/config/hello.txt` // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request for Get Object end point. req, err := newTestSignedRequestV4(http.MethodPut, getPutObjectURL("", bucketName, objectName),
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 24.1K bytes - Click Count (0) -
fess-crawler/src/main/resources/org/codelibs/fess/crawler/mime/tika-mimetypes.xml
<mime-type type="application/vnd.sun.xml.writer"> <sub-class-of type="application/zip"/> <glob pattern="*.sxw"/> </mime-type> <!-- can't currently find any diff in contents btwn writer and template. Must rely on extension --> <mime-type type="application/vnd.sun.xml.writer.template"> <sub-class-of type="application/vnd.sun.xml.writer"/> <glob pattern="*.stw"/> </mime-type>Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Oct 16 07:46:32 GMT 2025 - 320.2K bytes - Click Count (5) -
cmd/background-newdisks-heal-ops_gen.go
err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z *healingTracker) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 29 // write "ID" err = en.Append(0xde, 0x0, 0x1d, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.ID) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 24.6K bytes - Click Count (0) -
cmd/sts-handlers_test.go
}) if zerr != nil { adminLogIf(ctx, zerr) return nil } header.Method = zip.Deflate zwriter, zerr := zipWriter.CreateHeader(header) if zerr != nil { adminLogIf(ctx, zerr) return nil } if _, err := io.Copy(zwriter, r); err != nil { adminLogIf(ctx, err) } return nil } for _, f := range iamExportFiles {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 103.4K bytes - Click Count (1) -
guava/src/com/google/common/collect/Iterators.java
* <p>The {@code Iterable} equivalent of this method is either {@link Collections#enumeration} (if * you have a {@link Collection}), or {@code Iterators.asEnumeration(collection.iterator())}. */ // This is an adapter for cases in which users do need an Enumeration for whatever reason. @SuppressWarnings("JdkObsolete") public static <T extends @Nullable Object> Enumeration<T> asEnumeration(Iterator<T> iterator) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 16 12:42:11 GMT 2025 - 51.4K bytes - Click Count (0) -
fastapi/applications.py
app = FastAPI() @app.websocket("/ws") async def websocket_endpoint(websocket: WebSocket): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text(f"Message text was: {data}") ``` """ def decorator(func: DecoratedCallable) -> DecoratedCallable:Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 176.3K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* code changes, you can use <a * href="https://www.javadoc.io/doc/com.github.ben-manes.caffeine/guava/latest/com.github.benmanes.caffeine.guava/com/github/benmanes/caffeine/guava/CaffeinatedGuava.html">its * {@code CaffeinatedGuava} adapter class</a>, which lets you build a Guava {@code Cache} or a Guava * {@code LoadingCache} backed by a Guava {@code CacheLoader}. * * <p>Caffeine's API for asynchronous operations uses {@code CompletableFuture}: <a
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 51.6K bytes - Click Count (0)