- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 932 for closeFn (0.17 sec)
-
guava/src/com/google/common/util/concurrent/ClosingFuture.java
* * <pre>{@code * FluentFuture<UserName> userName = * ClosingFuture.submit( * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor), * executor) * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor) * .transform((closer, result) -> result.get("userName"), directExecutor())
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 98.7K bytes - Viewed (0) -
pkg/test/framework/scope.go
c.waitForDone() } // Upon returning, notify the parent that we're done. defer func() { close(s.closeChan) }() var err error // Do reverse walk for cleanup. for i := len(s.closers) - 1; i >= 0; i-- { c := s.closers[i] if nocleanup { if cc, ok := c.(*closer); ok && cc.noskip { continue } else if !ok { continue } } name := "lambda"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 21:55:23 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/core-execution/build-cache/src/main/java/org/gradle/caching/internal/controller/DefaultBuildCacheController.java
local.maybeStore(key, file); }); } @Override public void close() throws IOException { if (!closed) { closed = true; Closer closer = Closer.create(); closer.register(local); closer.register(remote); closer.close(); } } @VisibleForTesting static class PackOperationExecutor {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 08 08:29:47 UTC 2024 - 14K bytes - Viewed (0) -
src/net/http/transport.go
if err == nil { panic("nil error") } pc.broken = true if pc.closed == nil { pc.closed = err pc.t.decConnsPerHost(pc.cacheKey) // Close HTTP/1 (pc.alt == nil) connection. // HTTP/2 closes its connection itself. if pc.alt == nil { if err != errCallerOwnsConn { pc.conn.Close() } close(pc.closech) } } pc.mutateHeaderFunc = nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/MultiProcessSafeIndexedCacheTest.groovy
1 * backingCache.close() 0 * _._ } def "closes cache when closed"() { given: cacheOpened() when: cache.finishWork() then: 1 * fileAccess.writeFile(!null) >> { Runnable action -> action.run() } 1 * backingCache.close() 0 * _._ }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
// we find them, regardless of what the address policies need. // // 2. EVICTABLE: Connections not required by any address policy. This matches connections that // don't participate in any policy, plus connections whose policies won't be violated if the // connection is closed. We only close these if the idle connection limit is exceeded. //
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0) -
src/compress/gzip/gzip.go
if z.err != nil { return z.err } if z.closed { return nil } if !z.wroteHeader { z.Write(nil) if z.err != nil { return z.err } } z.err = z.compressor.Flush() return z.err } // Close closes the [Writer] by flushing any unwritten data to the underlying // [io.Writer] and writing the GZIP footer. // It does not close the underlying [io.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) -
cmd/metacache-stream.go
continue } } }() return objs, nil } // Close and release resources. func (w *metacacheWriter) Close() error { if w == nil || w.closer == nil { return nil } w.streamWg.Wait() err := w.closer() w.closer = nil return err } // Reset and start writing to new writer. // Close must have been called before this. func (w *metacacheWriter) Reset(out io.Writer) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0) -
src/runtime/os_plan9.go
fd := open(&buf[0], _OWRITE, 0) if fd < 0 { return -1 } len := findnull(&msg[0]) if write1(uintptr(fd), unsafe.Pointer(&msg[0]), int32(len)) != int32(len) { closefd(fd) return -1 } closefd(fd) return 0 } //go:nosplit func exit(e int32) { var status []byte if e == 0 { status = emptystatus } else { // build error string var tmp [32]byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 10.3K bytes - Viewed (0)