Adrian Bumbas adrianbumbas

adrianbumbas / WebSocketClientReactive.java

Created February 20, 2016 08:56

Reactive consuming a web socket using RxJava, Java8 and Tyrus client

	import org.glassfish.tyrus.ext.client.java8.SessionBuilder;
	import rx.Observable;

	import javax.websocket.Session;
	import java.io.IOException;
	import java.net.URI;
	import java.net.URISyntaxException;
	import java.util.concurrent.CountDownLatch;

	public class WebSocketClientReactive {