// Act
        SamrDomainHandle handle = new SamrDomainHandle(mockDcerpcHandle, mockPolicyHandle, access, mockSid);

        // Assert
        assertNotNull(handle);
        // Verify sendrecv was called once with the correct RPC message
        verify(mockDcerpcHandle, times(1)).sendrecv(openDomainCaptor.capture());
        MsrpcSamrOpenDomain capturedRpc = openDomainCaptor.getValue();
        assertNotNull(capturedRpc);

        // Execute with second engine
        Object result2 = scriptExecutor.execute("type2", "script for engine2");
        assertEquals("engine2:processed: script for engine2", result2);

        // Verify correct engine was called each time
        assertEquals("script for engine1", engine1.getLastScript());
        assertEquals("script for engine2", engine2.getLastScript());
    }

    @Test

    the standard is perfect, but having a consistent order makes the code more
    readable and no other order is compellingly better than the standard.
    The correct order is:
            public
            protected
            private
            abstract
            static
            final
            transient
            volatile
            synchronized

        }
        // We reschedule ourselves with a lock held for two reasons. 1. we want to make sure that
        // cancel calls cancel on the correct future. 2. we want to make sure that the assignment
        // to currentFuture doesn't race with itself so that currentFuture is assigned in the
        // correct order.
        Throwable scheduleFailure = null;
        Cancellable toReturn;
        lock.lock();
        try {

# Separate OpenAPI Schemas for Input and Output or Not { #separate-openapi-schemas-for-input-and-output-or-not }

Since **Pydantic v2** was released, the generated OpenAPI is a bit more exact and **correct** than before. 😎

In fact, in some cases, it will even have **two JSON Schemas** in OpenAPI for the same Pydantic model, for input and output, depending on if they have **default values**.

Let's see how that works and how to change it if you need to do that.

        // Then
        assertNotNull(address, "Should return address for IP address");
        assertEquals("127.0.0.1", address.getHostAddress(), "Should return correct IP address");
    }

    @Test
    @DisplayName("Should get all addresses by name")
    void testGetAllByName() throws UnknownHostException {
        // When

    with protocols like MCP that stream SSE over `POST`.

    The actual encoding logic lives in the FastAPI routing layer. This class
    serves mainly as a marker and sets the correct `Content-Type`.
    """

    media_type = "text/event-stream"


def _check_id_no_null(v: str | None) -> str | None:
    if v is not None and "\0" in v:

        // Then
        assertNotNull(resp);
        assertTrue(resp instanceof ServerMessageBlock2Response);
        assertTrue(resp instanceof ServerMessageBlock2);
    }

    @Test
    @DisplayName("Should return correct OVERHEAD constant value")
    void testOverheadConstant() {
        // Then
        assertEquals(Smb2Constants.SMB2_HEADER_LENGTH + 16, Smb2ReadResponse.OVERHEAD);
    }

    @Test

            request.writeBytesWireFormat(buffer, startIndex);

            // Verify data is at correct position
            for (int i = 0; i < data.length; i++) {
                assertEquals((byte) 0xAB, buffer[startIndex + 48 + i]);
            }
        }

        @Test
        @DisplayName("Should handle partial data buffer correctly")
        void testPartialDataBuffer() {
            byte[] fullData = new byte[200];

            fail("Array index calculation is incorrect: " + e.getMessage());
        }

        Object result = dataMap.get("test");
        assertTrue(result instanceof Object[]);
        Object[] resultArray = (Object[]) result;
        assertEquals(6, resultArray.length);

        // Verify all values are in correct positions
        assertEquals("initial", resultArray[0]);