- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 51 for unwrapping (0.36 sec)
-
internal/deadlineconn/deadlineconn.go
} // WithWriteDeadline sets a new write side net.Conn deadline. func (c *DeadlineConn) WithWriteDeadline(d time.Duration) *DeadlineConn { c.writeDeadline = d return c } // New - creates a new connection object wrapping net.Conn with deadlines. func New(c net.Conn) *DeadlineConn { return &DeadlineConn{ Conn: c, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 2.3K bytes - Viewed (0) -
src/io/ioutil/ioutil.go
return nil, err } slices.SortFunc(list, func(a, b os.FileInfo) int { return strings.Compare(a.Name(), b.Name()) }) return list, nil } // NopCloser returns a ReadCloser with a no-op Close method wrapping // the provided Reader r. // // Deprecated: As of Go 1.16, this function simply calls [io.NopCloser]. func NopCloser(r io.Reader) io.ReadCloser { return io.NopCloser(r) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3.2K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
package http import ( "bytes" "context" "crypto/tls" "errors" "io" "net" "net/http/internal/testcert" "strings" "testing" ) // Issue 15446: incorrect wrapping of errors when server closes an idle connection. func TestTransportPersistConnReadLoopEOF(t *testing.T) { ln := newLocalListener(t) defer ln.Close() connc := make(chan net.Conn, 1) go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
src/cmd/compile/internal/ssagen/abi.go
pos := base.AutogeneratedPos base.Pos = pos // At the moment we don't support wrapping a method, we'd need machinery // below to handle the receiver. Panic if we see this scenario. ft := f.Nname.Type() if ft.NumRecvs() != 0 { base.ErrorfAt(f.Pos(), 0, "makeABIWrapper support for wrapping methods not implemented") return } // Reuse f's types.Sym to create a new ODCLFUNC/function.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 13.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/session/scope/internal/SessionScope.java
+ "a org.eclipse.sisu.Typed or javax.enterprise.inject.Typed annotation"); } } /** * A provider wrapping an existing provider with a cache * @param <T> the provided type */ protected static class CachingProvider<T> implements Provider<T> { private final Provider<T> provider;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/api-router.go
tracedHandler = httpTraceHdrs(f) } else { tracedHandler = httpTraceAll(f) } // Skip wrapping with the gzip middleware if specified. var gzippedHandler http.HandlerFunc = tracedHandler if !handlerFlags.has(noGZS3HFlag) { gzippedHandler = gzipHandler(gzippedHandler) } // Skip wrapping with throttling middleware if specified. var throttledHandler http.HandlerFunc = gzippedHandler
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 22.8K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/EncryptionService.kt
* the exception is thrown. * * @param innerSupplier the supplier that produces the inner closeable that is to be safely wrapped * @param unsafeWrapper a wrapping function that is potentially unsafe * @return the result of the wrapper function */ private fun <C : Closeable, T : Closeable> safeWrap(innerSupplier: () -> C, unsafeWrapper: (C) -> T): T {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/api/internal/tasks/compile/DiagnosticToProblemListener.java
*/ // If this annotation is not present, all diagnostic messages would be wrapped in a ClientCodeWrapper. // We don't need this wrapping feature, hence the trusted annotation. @ClientCodeWrapper.Trusted public class DiagnosticToProblemListener implements DiagnosticListener<JavaFileObject> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 06:17:43 UTC 2024 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
type ProxyWatcher struct { result chan Event stopCh chan struct{} mutex sync.Mutex stopped bool } var _ Interface = &ProxyWatcher{} // NewProxyWatcher creates new ProxyWatcher by wrapping a channel func NewProxyWatcher(ch chan Event) *ProxyWatcher { return &ProxyWatcher{ result: ch, stopCh: make(chan struct{}), stopped: false, } } // Stop implements Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
pilot/cmd/pilot-agent/app/cmd.go
// Get IP only var ip net.IP switch v := addr.(type) { case *net.IPNet: ip = v.IP case *net.IPAddr: ip = v.IP default: continue } // handling ipv4 wrapping in ipv6 ipAddr, okay := netip.AddrFromSlice(ip) if !okay { continue } unwrapAddr := ipAddr.Unmap()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0)