Watch support in mock server

[thecrazzymouse]

I am trying to connect to a mocked Kubernetes server from kubectl.
This works flawlessly when creating listing resources, however if I would like to watch a resource it fails.

I have patched the
public class Http1xServerConnection extends Http1xConnectionBase implements HttpServerConnection {

private WebSocketServerHandshaker createHandshaker(Http1xServerRequest request) throws WebSocketHandshakeException {
    String connectionHeader = "upgrade";
    request.headers().add("connection", "upgrade");
    request.headers().add("upgrade", "websocket");
    request.headers().add("origin", "thx");

now the connection goes through, but the messages never appear.

My guess is that Kubernetes is not a standard web socket solution, so

    this.executor.schedule(() -> ((WebSocket)this.webSocketRef.get()).send(message.getBody()), message.getDelay(), TimeUnit.SECONDS);

here the messages would need to be encoded somehow.

So what needs to be done so what kubectl will also able to watch?