}

    @Test
    void testConstructor() {
        assertNotNull(channelManager);
        assertFalse(channelManager.isUseMultiChannel());
        assertEquals(0, channelManager.getChannels().size());
        assertNotNull(channelManager.getLoadBalancer());
    }

    @Test
    void testInitializationWithoutMultiChannelSupport() throws IOException {

    }

    @Test
    void testMultiChannelInitialization() throws Exception {
        // Test that ChannelManager initializes properly
        assertNotNull(channelManager);
        assertNotNull(channelManager.getChannels());
        // Note: isUseMultiChannel() checks if actual multi-channel is negotiated with server
        // In mock environment, this will be false until we mock successful negotiation

      FileOperator(
        randomAccessFile!!.getChannel(),
      )
    val buffer = Buffer()
    operator.read(0, buffer, 5)
    assertThat(buffer.readUtf8()).isEqualTo("Hello")
    operator.read(4, buffer, 5)
    assertThat(buffer.readUtf8()).isEqualTo("o, Wo")
  }

  @Test
  fun write() {
    val operator =
      FileOperator(
        randomAccessFile!!.getChannel(),
      )

        assertArgumentNotNull("file", file);

        final FileInputStream is = InputStreamUtil.create(file);
        try {
            final FileChannel channel = is.getChannel();
            final ByteBuffer buffer = ByteBuffer.allocate((int) ChannelUtil.size(channel));
            ChannelUtil.read(channel, buffer);
            return buffer.array();
        } finally {

  override fun getTrafficClass(): Int = delegate!!.trafficClass

  @Throws(IOException::class)
  override fun sendUrgentData(value: Int) {
    delegate!!.sendUrgentData(value)
  }

  override fun getChannel(): SocketChannel = delegate!!.channel

  override fun getHandshakeSession(): SSLSession = delegate!!.handshakeSession

  override fun getApplicationProtocol(): String = delegate!!.applicationProtocol