public void connect() throws ConnectException {
        connect(s -> {}, t -> {}, () -> {});
    }
@Test
    public void testInterruptCurrentThreadIfConnectionIsInterrupted() throws Exception {
        when(webSocketClient.connectBlocking()).thenThrow(new InterruptedException());
        service.connect();

        assertTrue(Thread.currentThread().isInterrupted(), "Interrupted flag was not set properly");
    }