- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 717 for handler (0.07 seconds)
-
impl/maven-core/src/main/java/org/apache/maven/project/DefaultMavenProjectHelper.java
MavenProject project, String artifactType, String artifactClassifier, File artifactFile) { ArtifactHandler handler = null; if (artifactType != null) { handler = artifactHandlerManager.getArtifactHandler(artifactType); } if (handler == null) { handler = artifactHandlerManager.getArtifactHandler("jar"); }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 4.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
when (type) { TYPE_DATA -> readData(handler, length, flags, streamId) TYPE_HEADERS -> readHeaders(handler, length, flags, streamId) TYPE_PRIORITY -> readPriority(handler, length, flags, streamId) TYPE_RST_STREAM -> readRstStream(handler, length, flags, streamId) TYPE_SETTINGS -> readSettings(handler, length, flags, streamId) TYPE_PUSH_PROMISE -> readPushPromise(handler, length, flags, streamId)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 19.8K bytes - Click Count (0) -
internal/grid/README.md
From this connection individual requests can be made. Each handler, with optional subroutes can be registered with the manager using `Manager.RegisterXHandler(handlerID, handler, subroutes...)`. A `Handler()` function provides an HTTP handler, which should be hooked up to the appropriate route on the server.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/http/server.go
return } atomic.AddInt32(&srv.requestCount, 1) defer atomic.AddInt32(&srv.requestCount, -1) // Handle request using passed handler. handler.ServeHTTP(w, r) }) srv.listenerMutex.Lock() srv.Handler = wrappedHandler srv.listener = listener srv.listenerMutex.Unlock() var l net.Listener = listener if tlsConfig != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (0) -
internal/grid/connection_test.go
} errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } wrapServer := func(handler http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { t.Logf("Got a %s request for: %v", r.Method, r.URL) handler.ServeHTTP(w, r) }) } connReady := make(chan struct{}) // We fake a local and remote server. localHost := hosts[0]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 5.9K bytes - Click Count (0) -
internal/grid/grid_test.go
handler2 := func(req *testRequest) (resp *testResponse, err *RemoteErr) { r := RemoteErr(req.String) return nil, &r } errFatal(h1.Register(local, handler1)) errFatal(h2.Register(local, handler2)) errFatal(h1.Register(remote, handler1)) errFatal(h2.Register(remote, handler2)) // local to remote connection
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
cmd/metrics-router.go
auth = NoAuthMiddleware } metricsRouter.Handle(prometheusMetricsPathLegacy, auth(metricsHandler())) metricsRouter.Handle(prometheusMetricsV2ClusterPath, auth(metricsServerHandler())) metricsRouter.Handle(prometheusMetricsV2BucketPath, auth(metricsBucketHandler())) metricsRouter.Handle(prometheusMetricsV2NodePath, auth(metricsNodeHandler())) metricsRouter.Handle(prometheusMetricsV2ResourcePath, auth(metricsResourceHandler()))
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jul 15 16:28:02 GMT 2024 - 2.6K bytes - Click Count (0) -
docs/en/docs/advanced/events.md
In this case, the `startup` event handler function will initialize the items "database" (just a `dict`) with some values. You can add more than one event handler function. And your application won't start receiving requests until all the `startup` event handlers have completed. ### `shutdown` event { #shutdown-event }
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 7.9K bytes - Click Count (0) -
internal/http/server_test.go
nonLoopBackIP := getNonLoopBackIP(t) handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hello, world") }) testCases := []struct { addrs []string handler http.Handler certFn certs.GetCertificateFunc }{ {[]string{"127.0.0.1:9000"}, handler, nil}, {[]string{nonLoopBackIP + ":9000"}, handler, nil},
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Jun 19 18:42:47 GMT 2024 - 2.5K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java
ArtifactHandler handler = manager.getArtifactHandler(id); type = new DefaultType( id, languageRegistry.lookup(handler.getLanguage()).orElseGet(() -> handler::getLanguage), handler.getExtension(), handler.getClassifier(), handler.isIncludesDependencies(),
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed May 14 04:47:58 GMT 2025 - 4K bytes - Click Count (0)