- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 70 for Regisser (0.33 sec)
-
android/guava-tests/test/com/google/common/io/CloserTest.java
} public void testNoExceptionsThrown() throws IOException { Closer closer = new Closer(suppressor); TestCloseable c1 = closer.register(TestCloseable.normal()); TestCloseable c2 = closer.register(TestCloseable.normal()); TestCloseable c3 = closer.register(TestCloseable.normal()); assertFalse(c1.isClosed()); assertFalse(c2.isClosed()); assertFalse(c3.isClosed()); closer.close();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Mar 06 15:15:46 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/peer-rest-server.go
logger.FatalIf(getMetacacheListingRPC.Register(gm, server.GetMetacacheListingHandler), "unable to register handler") logger.FatalIf(getMetricsRPC.Register(gm, server.GetMetricsHandler), "unable to register handler") logger.FatalIf(getNetInfoRPC.Register(gm, server.GetNetInfoHandler), "unable to register handler") logger.FatalIf(getOSInfoRPC.Register(gm, server.GetOSInfoHandler), "unable to register handler")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
tests/callbacks_test.go
func TestCallbacksRemove(t *testing.T) { db, _ := gorm.Open(nil, nil) createCallback := db.Callback().Create() createCallback.Before("*").Register("c1", c1) createCallback.After("*").Register("c2", c2) createCallback.Before("c4").Register("c3", c3) createCallback.After("c2").Register("c4", c4) // callbacks: []string{"c1", "c3", "c4", "c2"} createCallback.Remove("c1")
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Mar 26 03:33:36 GMT 2024 - 7.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CloserTest.java
} public void testNoExceptionsThrown() throws IOException { Closer closer = new Closer(suppressor); TestCloseable c1 = closer.register(TestCloseable.normal()); TestCloseable c2 = closer.register(TestCloseable.normal()); TestCloseable c3 = closer.register(TestCloseable.normal()); assertFalse(c1.isClosed()); assertFalse(c2.isClosed()); assertFalse(c3.isClosed()); closer.close();
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) -
cmd/routers.go
func registerDistErasureRouters(router *mux.Router, endpointServerPools EndpointServerPools) { // Register storage REST router only if its a distributed setup. registerStorageRESTHandlers(router, endpointServerPools, globalGrid.Load()) // Register peer REST router only if its a distributed setup. registerPeerRESTHandlers(router, globalGrid.Load()) // Register bootstrap REST router for distributed setups. registerBootstrapRESTHandlers(globalGrid.Load())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
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 remoteConn := local.Connection(remoteHost) const testPayload = "Hello Grid World!"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
ci/official/wheel_test/WORKSPACE
) python_repository(name = "python_version_repo") load("@python_version_repo//:py_version.bzl", "TF_PYTHON_VERSION") # Register multi toolchains load("@rules_python//python:repositories.bzl", "python_register_toolchains") # buildifier: disable=same-origin-load python_register_toolchains( name = "python", ignore_root_user_error = True, python_version = TF_PYTHON_VERSION, )
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Apr 05 22:27:48 GMT 2024 - 1.9K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleUserManualPlugin.java
Provider<Directory> generatedDirectory = extension.getUserManual().getStagingRoot().dir("generated"); TaskProvider<GenerateApiMapping> apiMapping = tasks.register("apiMapping", GenerateApiMapping.class, task -> { task.getMetaDataFile().convention(extension.getDslReference().getGeneratedMetaDataFile());
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Mar 01 05:46:51 GMT 2024 - 17.7K bytes - Viewed (0) -
cmd/storage-rest-server.go
logger.FatalIf(storageRenameDataInlineRPC.Register(gm, server.RenameDataInlineHandler, endpoint.Path), "unable to register handler") logger.FatalIf(storageDeleteFileRPC.Register(gm, server.DeleteFileHandler, endpoint.Path), "unable to register handler") logger.FatalIf(storageCheckPartsRPC.Register(gm, server.CheckPartsHandler, endpoint.Path), "unable to register handler")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/grid/handlers.go
} // Register a handler for two-way streaming with payload, input stream and output stream. // An optional subroute can be given. Multiple entries are joined with '/'. func (h *StreamTypeHandler[Payload, Req, Resp]) Register(m *Manager, handle func(ctx context.Context, p Payload, in <-chan Req, out chan<- Resp) *RemoteErr, subroute ...string) error { return h.register(m, handle, subroute...) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0)