add setWebSocket0 extension method (#1447)

thabach · slandelle · commit b9ca9f46b935 · 2017-08-03T14:33:29.000+02:00
diff --git a/client/src/main/java/org/asynchttpclient/ws/WebSocketUpgradeHandler.java b/client/src/main/java/org/asynchttpclient/ws/WebSocketUpgradeHandler.java
@@ -37,6 +37,7 @@ public WebSocketUpgradeHandler(List<WebSocketListener> listeners) {
         this.listeners = listeners;
     }
     
+    protected void setWebSocket0(NettyWebSocket webSocket) {}
     protected void onStatusReceived0(HttpResponseStatus responseStatus) throws Exception {}
     protected void onHeadersReceived0(HttpHeaders headers) throws Exception {}
     protected void onBodyPartReceived0(HttpResponseBodyPart bodyPart) throws Exception {}
@@ -81,6 +82,7 @@ public final void onThrowable(Throwable t) {
 
     public final void setWebSocket(NettyWebSocket webSocket) {
         this.webSocket = webSocket;
+        setWebSocket0(this.webSocket);
     }
     
     public final void onOpen() {

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,7 @@ public WebSocketUpgradeHandler(List<WebSocketListener> listeners) {`
`37`	`37`	`this.listeners = listeners;`
`38`	`38`	`}`
`39`	`39`
	`40`	`+ protected void setWebSocket0(NettyWebSocket webSocket) {}`
`40`	`41`	`protected void onStatusReceived0(HttpResponseStatus responseStatus) throws Exception {}`
`41`	`42`	`protected void onHeadersReceived0(HttpHeaders headers) throws Exception {}`
`42`	`43`	`protected void onBodyPartReceived0(HttpResponseBodyPart bodyPart) throws Exception {}`
`@@ -81,6 +82,7 @@ public final void onThrowable(Throwable t) {`
`81`	`82`
`82`	`83`	`public final void setWebSocket(NettyWebSocket webSocket) {`
`83`	`84`	`this.webSocket = webSocket;`
	`85`	`+ setWebSocket0(this.webSocket);`
`84`	`86`	`}`
`85`	`87`
`86`	`88`	`public final void onOpen() {`