registered - Code Search

guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java

    assertEquals(0, registry.getSubscribersForTesting(String.class).size());

    registry.register(new StringSubscriber());
    assertEquals(1, registry.getSubscribersForTesting(String.class).size());

    registry.register(new StringSubscriber());
    assertEquals(2, registry.getSubscribersForTesting(String.class).size());

    registry.register(new ObjectSubscriber());
    assertEquals(2, registry.getSubscribersForTesting(String.class).size());

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 19 18:03:30 GMT 2024

- 5.8K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java

    assertEquals(0, registry.getSubscribersForTesting(String.class).size());

    registry.register(new StringSubscriber());
    assertEquals(1, registry.getSubscribersForTesting(String.class).size());

    registry.register(new StringSubscriber());
    assertEquals(2, registry.getSubscribersForTesting(String.class).size());

    registry.register(new ObjectSubscriber());
    assertEquals(2, registry.getSubscribersForTesting(String.class).size());

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 19 18:03:30 GMT 2024

- 5.8K bytes

- Click Count (0)

github.com/golang/go

src/cmd/asm/internal/asm/testdata/riscv64error.s

	VSSE8V		V3, X11, V1, (X10)		// ERROR "invalid vector mask register"
	VLUXEI8V	(X10), V2, V1, V3		// ERROR "invalid vector mask register"
	VSUXEI8V	V3, V2, V1, (X10)		// ERROR "invalid vector mask register"
	VLOXEI8V	(X10), V2, V1, V3		// ERROR "invalid vector mask register"
	VSOXEI8V	V3, V2, V1, (X10)		// ERROR "invalid vector mask register"
	VLSEG2E8V	(X10), V1, V3			// ERROR "invalid vector mask register"

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Wed Sep 24 13:21:53 GMT 2025

- 26.8K bytes

- Click Count (0)

github.com/golang/go

src/cmd/asm/internal/arch/arm64.go

		}
	}
	return 0, false
}

// ARM64RegisterShift constructs an ARM64 register with shift operation.
func ARM64RegisterShift(reg, op, count int16) (int64, error) {
	// the base register of shift operations must be general register.
	if reg > arm64.REG_R31 || reg < arm64.REG_R0 {
		return 0, errors.New("invalid register for shift operation")
	}
	return int64(reg&31)<<16 | int64(op)<<22 | int64(uint16(count)), nil
}

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Thu Oct 16 00:35:29 GMT 2025

- 6.3K bytes

- Click Count (0)

github.com/google/guava

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();

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Oct 28 16:03:47 GMT 2025

- 11.8K bytes

- Click Count (0)

github.com/minio/minio

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")

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 53.6K bytes

- Click Count (0)

github.com/minio/minio

cmd/api-router.go

		statsCollectedHandler := collectAPIStats(handlerName, throttledHandler)

		// Call the final handler.
		statsCollectedHandler(w, r)
	}

	return handler
}

// registerAPIRouter - registers S3 compatible APIs.
func registerAPIRouter(router *mux.Router) {
	// Initialize API.
	api := objectAPIHandlers{
		ObjectAPI: newObjectLayerFn,
	}

	// API Router

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Oct 24 04:05:19 GMT 2025

- 23.3K bytes

- Click Count (0)

github.com/minio/minio

cmd/lock-rest-server.go

	logger.FatalIf(lockRPCUnlock.Register(gm, lockServer.UnlockHandler), "unable to register handler")
	logger.FatalIf(lockRPCRLock.Register(gm, lockServer.RLockHandler), "unable to register handler")
	logger.FatalIf(lockRPCRUnlock.Register(gm, lockServer.RUnlockHandler), "unable to register handler")

	globalLockServer = lockServer.ll

	go lockMaintenance(GlobalContext)
}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Jan 31 19:54:34 GMT 2025

- 6.3K bytes

- Click Count (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.30.md

- Etcd image `v3.5.12` has been built. ([#123069](https://github.com/kubernetes/kubernetes/pull/123069), [@bzsuni](https://github.com/bzsuni))
- Fixed a bug in scheduler requeueing where registered wildcard cluster event sources didn't work. ([#123117](https://github.com/kubernetes/kubernetes/pull/123117), [@kerthcet](https://github.com/kerthcet))

Created: Fri Dec 26 09:05:12 GMT 2025

- Last Modified: Wed Jun 18 18:59:10 GMT 2025

- 398.1K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleDslReferencePlugin.java

        TaskProvider<ExtractDslMetaDataTask> dslMetaData = tasks.register("dslMetaData", ExtractDslMetaDataTask.class, task -> {
            task.source(extension.getDocumentedSource());
            task.getDestinationFile().convention(dslReference.getStagingRoot().file("dsl-meta-data.bin"));
        });

        TaskProvider<AssembleDslDocTask> dslDocbook = tasks.register("dslDocbook", AssembleDslDocTask.class, task -> {

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Wed Dec 09 08:14:05 GMT 2020

- 5.7K bytes

- Click Count (0)

Search Options