Package io.karatelabs.http

Class WsConnection

java.lang.Object
io.karatelabs.http.WsConnection
public class WsConnection extends Object
WebSocket connection wrapping a Netty channel. Provides methods to send messages, register callbacks for incoming messages, and manage the connection lifecycle.

  • Method Details

    • send

      public void send(String text)
      Send a text message.

    • sendBytes

      public void sendBytes(byte[] data)
      Send a binary message.

    • onMessage

      public void onMessage(Consumer<String> handler)
      Register a callback for incoming text messages.

    • onBinary

      public void onBinary(Consumer<byte[]> handler)
      Register a callback for incoming binary messages.

    • onClose

      public void onClose(Runnable callback)
      Register a callback for when the connection closes.

    • close

      public void close()
      Close the WebSocket connection with a normal closure.

    • close

      public void close(int code, String reason)
      Close the WebSocket connection with a specific status code and reason.

    • isOpen

      public boolean isOpen()