* This class handles DFS referral responses that redirect clients to alternate servers for accessing
 * distributed file system resources, supporting multiple DFS versions and referral types.
 */
public class Referral implements Decodable {

    /**
     * Default constructor for Referral.
     */
    public Referral() {
        // Default constructor
    }

        writeLittleEndianInt(baos, PacConstants.LOGON_INFO); // type
        writeLittleEndianInt(baos, 10); // size
        writeLittleEndianLong(baos, 25); // Unaligned offset (not multiple of 8)
        // Add enough data to avoid array bounds issues
        while (baos.size() < 35) {
            baos.write(0);
        }
        byte[] pacData = baos.toByteArray();

        @DisplayName("Should allow close method to be called multiple times")
        void shouldAllowMultipleCloseCallsOnMock() throws Exception {
            SmbSession mockSession = mock(SmbSession.class);
            doNothing().when(mockSession).close();

            assertDoesNotThrow(() -> {
                mockSession.close();
                mockSession.close();
            }, "Multiple close() calls should not throw exceptions");

        assertTrue(response instanceof ServerMessageBlock2);
        assertTrue(response instanceof CommonServerMessageBlockResponse);
    }

    @Test
    @DisplayName("Should handle multiple read operations")
    void testMultipleReads() throws SMBProtocolDecodingException {
        // Given
        byte[] buffer1 = new byte[256];
        byte[] buffer2 = new byte[256];

///

Com isso você pode conectar o WebSocket e então enviar e receber mensagens:

<img src="/img/tutorial/websockets/image05.png">

## Lidando com desconexões e múltiplos clientes

Quando uma conexão WebSocket é fechada, o `await websocket.receive_text()` levantará uma exceção `WebSocketDisconnect`, que você pode então capturar e lidar como neste exemplo.

          "CERTIFICATE" -> {
            require(certificatePem == null) { "string includes multiple certificates" }
            certificatePem = match.groups[0]!!.value // Keep --BEGIN-- and --END-- for certificates.
          }
          "PRIVATE KEY" -> {
            require(pkcs8Base64 == null) { "string includes multiple private keys" }
            pkcs8Base64 = match.groups[2]!!.value // Include the contents only for PKCS8.

 *
 * Since connections may be reused, the proxy selection, DNS, and connect events may not be present
 * for a call. In future releases of OkHttp these events may also occur concurrently to permit
 * multiple routes to be attempted simultaneously.
 *
 * Events and sequences of events may be repeated for retries and follow-ups.
 *
 * All event methods must execute fast, without external locking, cannot throw exceptions, attempt

  public static ArrayBasedEscaperMap create(Map<Character, String> replacements) {
    return new ArrayBasedEscaperMap(createReplacementArray(replacements));
  }

  // The underlying replacement array we can share between multiple escaper
  // instances.
  private final char[][] replacementArray;

  private ArrayBasedEscaperMap(char[][] replacementArray) {
    this.replacementArray = replacementArray;
  }

    val builderList: List<KeyStore.Builder> =
      listOf(
        KeyStore.Builder.newInstance("PKCS11", null, KeyStore.CallbackHandlerProtection(callbackHandler)),
        // Example if you want to combine multiple keystore types
        // KeyStore.Builder.newInstance("PKCS12", null, File("keystore.p12"), PasswordProtection("rosebud".toCharArray()))
      )

    val keyManagerFactory = KeyManagerFactory.getInstance("NewSunX509")

        }

        for (int i = 0; i < items.length; i++) {
            assertEquals(i + 1, items[i].getId());
        }
    }

    public void test_idModification() {
        // Test modifying ID value multiple times
        TestDictionaryItem item = new TestDictionaryItem();

        // Initial value
        assertEquals(0L, item.getId());

        // First modification
        item.id = 50L;