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();
It could be nice to add to MockServer a close method for the
andUpgradeToWebSocket
.Example: https://github.com/fabric8io/kubernetes-client/blob/master/kubernetes-tests/src/test/java/io/fabric8/kubernetes/client/mock/PodTest.java#L318-L344
could become: