- Sort Score
- Result 10 results
- Languages All
Results 771 - 780 of 1,088 for closer (0.08 sec)
-
guava-tests/test/com/google/common/io/CharSequenceReaderTest.java
assertThrows(IllegalArgumentException.class, () -> reader.mark(-1)); } public void testMethodsThrowWhenClosed() throws IOException { CharSequenceReader reader = new CharSequenceReader(""); reader.close(); assertThrows(IOException.class, () -> reader.read()); assertThrows(IOException.class, () -> reader.read(new char[10])); assertThrows(IOException.class, () -> reader.read(new char[10], 0, 10));
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.5K bytes - Viewed (0) -
internal/config/lambda/parse.go
return err } targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return err } for _, target := range targetList { defer target.Close() } for _, target := range targetList { yes, err := target.IsActive() if err == nil && !yes { err = ErrTargetsOffline } if err != nil { return fmt.Errorf("error (%s): %w", target.ID(), err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
internal/http/response-recorder.go
if lrw.Header().Get("Content-Encoding") == "gzip" { if lrw.body.Len() > 1<<20 { return gzippedBody } r, err := gzip.NewReader(&lrw.body) if err != nil { return gzippedBody } defer r.Close() b, _ := io.ReadAll(io.LimitReader(r, 10<<20)) return b } // If there was an error response or body logging is enabled // then we return the body contents
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 5.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/NtStatus.java
"The pipe state is invalid.", "All pipe instances are busy.", "No process is on the other end of the pipe.", "The pipe is being closed.", "Waiting for a process to open the other end of the pipe.", "File is a directory.", "A duplicate name exists on the network.",
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sat Jun 01 10:09:29 UTC 2019 - 11.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NameServiceClient.java
* because we might close the socket during a * request. However the chances are slim and the * retry code should ensure the overall request * is serviced. The alternative complicates things * more than I think is worth it. */ if( socket != null ) { socket.close(); socket = null; }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 17.4K bytes - Viewed (0) -
architecture/ambient/ztunnel-cni-lifecycle.md
This can help ensure that clients do not hold onto pooled connections for too long. This is not strictly required; Ztunnel clients have both keepalives (which will start to fail once the other end is shut down) and pool idle timeouts (which will close the connection when it has had no activity for some period; because the backend is gone, there will be no activity). However, it would be ideal to give immediate feedback rather than relying on these mechanisms.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jul 17 23:10:17 UTC 2024 - 9.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't * predictable what work might be done. (e.g., close a file and flush buffers to disk). To * protect ourselves from this, we park ourselves and tell our interrupter that we did so. */ if (state == PARKED || compareAndSet(state, PARKED)) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 10.1K bytes - Viewed (0) -
docs/pt/docs/tutorial/request-files.md
* Por exemplo, `await myfile.seek(0)` irá para o início do arquivo. * Isso é especialmente útil se você executar `await myfile.read()` uma vez e precisar ler o conteúdo novamente. * `close()`: Fecha o arquivo. Como todos esses métodos são métodos `assíncronos`, você precisa "aguardar" por eles. Por exemplo, dentro de uma função de *operação de rota* `assíncrona`, você pode obter o conteúdo com: ```Python
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Oct 30 19:52:32 UTC 2024 - 7.8K bytes - Viewed (0) -
callbacks/update.go
dest := db.Statement.Dest db.Statement.Dest = db.Statement.ReflectValue.Addr().Interface() gorm.Scan(rows, db, mode) db.Statement.Dest = dest db.AddError(rows.Close()) } } else { result, err := db.Statement.ConnPool.ExecContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...) if db.AddError(err) == nil {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Mar 18 05:44:55 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
return } resp, err := target.Send(eventData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer resp.Body.Close() if eventData.GetObjectContext.OutputRoute != resp.Header.Get(xhttp.AmzRequestRoute) { tokenErr := errorCodes.ToAPIErr(ErrInvalidRequest) tokenErr.Description = "The request route included in the request is invalid"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 10.3K bytes - Viewed (0)