@@ -73,45 +73,49 @@ class BidirectionalWebsocketRouter extends JSONRPC.RouterBase
7373 } ;
7474
7575
76- if ( webSocket . addEventListener )
76+ if ( webSocket . on )
7777 {
78- webSocket . addEventListener (
78+ webSocket . on (
7979 "message" ,
80- async ( messageEvent ) => {
81- await this . _routeMessage ( messageEvent . data , objSession ) ;
80+ ( strData , objFlags ) => {
81+ this . _routeMessage ( strData , objSession ) ;
8282 }
8383 ) ;
8484
85- webSocket . addEventListener (
85+ webSocket . on (
8686 "close" ,
87- ( closeEvent ) => {
88- //closeEvent.code;
89- //closeEvent.reason;
90- //closeEvent.wasClean;
91-
87+ ( nCode , strReason ) => {
9288 this . onConnectionEnded ( nConnectionID ) ;
9389 }
9490 ) ;
9591
96- webSocket . addEventListener ( "error" , fnOnError ) ;
92+ webSocket . on ( "error" , fnOnError ) ;
9793 }
98- else
94+ else if ( webSocket . addEventListener )
9995 {
100- webSocket . on (
96+ webSocket . addEventListener (
10197 "message" ,
102- async ( strData , objFlags ) => {
103- await this . _routeMessage ( strData , objSession ) ;
98+ ( messageEvent ) => {
99+ this . _routeMessage ( messageEvent . data , objSession ) ;
104100 }
105101 ) ;
106102
107- webSocket . on (
103+ webSocket . addEventListener (
108104 "close" ,
109- ( nCode , strReason ) => {
105+ ( closeEvent ) => {
106+ //closeEvent.code;
107+ //closeEvent.reason;
108+ //closeEvent.wasClean;
109+
110110 this . onConnectionEnded ( nConnectionID ) ;
111111 }
112112 ) ;
113113
114- webSocket . on ( "error" , fnOnError ) ;
114+ webSocket . addEventListener ( "error" , fnOnError ) ;
115+ }
116+ else
117+ {
118+ throw new Error ( "Not a supported WebSocket interface." ) ;
115119 }
116120
117121
0 commit comments