server.expect().withPath("/api/v1/namespaces/test/pods/pod1/exec?command=ls&stdout=true")
.andUpgradeToWebSocket()
.open()
.waitFor(1000).andEmit(new OutputStreamMessage("first message"))
.waitFor(2000).andEmit(new OutputStreamMessage("second message"))
.waitFor(3000).andEmit(new CloseReason(1000, "Status v1 as string")) // this will close the session
.done()
.always();