- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 620 for closed (0.16 sec)
-
internal/rest/client.go
return } // ErrClientClosed returned when *Client is closed. var ErrClientClosed = errors.New("rest client is closed") // Call - make a REST call with context. func (c *Client) Call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) { switch atomic.LoadInt32(&c.connected) { case closed: // client closed, this is usually a manual process
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode} } // Fd returns the file descriptor func (f *fakeNs) Fd() uintptr { return f.fd } func (f *fakeNs) Inode() uint64 { return f.inode } // Close simulates closing the file descriptor and returns nil for no error func (f *fakeNs) Close() error { f.closed.Store(true) return nil } func fakeFs() fs.FS {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/ContiguousSet.java
* (inclusive) to {@code upper} (inclusive). (These are the same values contained in {@code * Range.closed(lower, upper)}.) * * @throws IllegalArgumentException if {@code lower} is greater than {@code upper} * @since 23.0 */ public static ContiguousSet<Integer> closed(int lower, int upper) { return create(Range.closed(lower, upper), DiscreteDomain.integers()); } /**
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Nov 30 21:54:06 GMT 2023 - 9.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CloserTest.java
assertFalse(c2.isClosed()); assertFalse(c3.isClosed()); closer.close(); assertTrue(c1.isClosed()); assertTrue(c2.isClosed()); assertTrue(c3.isClosed()); assertTrue(suppressor.suppressions.isEmpty()); } public void testExceptionThrown_fromTryBlock() throws IOException { Closer closer = new Closer(suppressor); TestCloseable c1 = closer.register(TestCloseable.normal());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Mar 06 15:15:46 GMT 2024 - 13.6K bytes - Viewed (0) -
src/test/java/org/codelibs/core/io/CloseableUtilTest.java
CloseableUtil.close(out); } private static class NotifyOutputStream extends OutputStream { private String notify_; @Override public void write(final int arg0) throws IOException { } @Override public void close() throws IOException { super.close(); notify_ = "closed"; }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseCommonTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
src/archive/zip/writer.go
w.comment = comment return nil } // Close finishes writing the zip file by writing the central directory. // It does not close the underlying writer. func (w *Writer) Close() error { if w.last != nil && !w.last.closed { if err := w.last.close(); err != nil { return err } w.last = nil } if w.closed { return errors.New("zip: writer closed twice") } w.closed = true // write central directory
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) -
internal/http/close.go
) // DrainBody close non nil response with any response Body. // convenient wrapper to drain any remaining data on response body. // // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests. func DrainBody(respBody io.ReadCloser) { // Callers should close resp.Body when done reading from it. // If resp.Body is not closed, the Client's underlying RoundTripper
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} } // Avoid infinite recursion if a closeable's close() method throws RejectedExecutionException and // is closed using the direct executor. public void testCloseThrowsRejectedExecutionException() throws Exception { doThrow(new RejectedExecutionException()).when(mockCloseable).close(); ClosingFuture<Closeable> closingFuture = ClosingFuture.submit(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
) { get().log("[ES] onEvent", Platform.INFO, null) events.add(Event(id, type, data)) drainCancelQueue(eventSource) } override fun onClosed(eventSource: EventSource) { get().log("[ES] onClosed", Platform.INFO, null) events.add(Closed) drainCancelQueue(eventSource) } override fun onFailure( eventSource: EventSource, t: Throwable?, response: Response?, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0)