List<?> exp = copyToList(expected);
    List<?> act = copyToList(actual);
    String actString = act.toString();

    // Of course we could take pains to give the complete description of the
    // problem on any failure.

    // Yeah it's n^2.
    for (Object object : exp) {
      if (!act.remove(object)) {
        fail(

        helper.tryStartOperation("test_op", null, 1);
        assertEquals(1, passedRetries.get());
    }

    @Test
    public void test_tryCleanupAndRetry_decrementsRetries() {
        // Verify that on retry chain, remainingRetries is decremented
        final List<Integer> retriesSeen = new ArrayList<>();
        final CoordinatorHelper helper = new CoordinatorHelper() {
            @Override

    ReferenceEntry<Object, Object> entry = null;
    for (int i = 0; i < originalCount; i++) {
      Object key = new Object();
      Object value = new Object();
      int hash = map.hash(key);
      // chain all entries together as we only have a single bucket
      entry = map.newEntry(key, hash, entry);
      ValueReference<Object, Object> valueRef = map.newValueReference(entry, value, 1);
      entry.setValueReference(valueRef);

    ReferenceEntry<Object, Object> entry = null;
    for (int i = 0; i < originalCount; i++) {
      Object key = new Object();
      Object value = new Object();
      int hash = map.hash(key);
      // chain all entries together as we only have a single bucket
      entry = map.newEntry(key, hash, entry);
      ValueReference<Object, Object> valueRef = map.newValueReference(entry, value, 1);
      entry.setValueReference(valueRef);

     *
     * <p>This method exists so that the {@link Segment} code can be generic in terms of {@code S},
     * the type of the concrete implementation.
     */
    abstract S self();

    /** Drains the reference queues used by this segment, if any. */
    @GuardedBy("this")
    void maybeDrainReferenceQueues() {}

    /** Clears the reference queues used by this segment, if any. */

			Optional:    true,
			Type:        "duration",
		},
		config.HelpKV{
			Key:         target.NATSCertAuthority,
			Description: "path to certificate chain of the target NATS server",
			Optional:    true,
			Type:        "string",
			Sensitive:   true,
		},
		config.HelpKV{
			Key:         target.NATSClientCert,
			Description: "client cert for NATS mTLS auth",

        // Test constructor with config and andx
        TestAndXServerMessageBlock block3 = new TestAndXServerMessageBlock(mockConfig) {
            {
                // Set andx via constructor chain
                super.setCommand((byte) 0x25);
            }
        };
        assertNotNull(block3);
    }

        assertEquals(1, notifications.size());
        assertEquals(action, notifications.get(0).getAction());
    }

    @Test
    @DisplayName("Should handle notification chain with alignment")
    void testNotificationChainAlignment() throws Exception {
        // Given - notifications must be 4-byte aligned
        byte[] buffer = new byte[1024];
        int offset = 0;

                    if (transport.isSMB2()) {
                        final Smb2TreeConnectRequest req = new Smb2TreeConnectRequest(sess.getConfig(), unc);
                        if (andx != null) {
                            req.chain((ServerMessageBlock2) andx);
                        }
                        request = req;
                    } else {

        return param


class SecurityScopes:
    """
    This is a special class that you can define in a parameter in a dependency to
    obtain the OAuth2 scopes required by all the dependencies in the same chain.

    This way, multiple dependencies can have different scopes, even when used in the
    same *path operation*. And with this, you can access all the scopes required in
    all those dependencies in a single place.