|
134 | 134 | dispatch(jet.DISCONNECT,e); |
135 | 135 | }; |
136 | 136 |
|
| 137 | + ws.onerror = function (e){ |
| 138 | + state = 2; |
| 139 | + dispatch(jet.EXCEPTION,e); |
| 140 | + }; |
| 141 | + |
137 | 142 | me.addHandler = function(eventName, callback){ |
138 | 143 | callbacks[eventName] = callbacks[eventName] || []; |
139 | 144 | callbacks[eventName].push(callback); |
140 | 145 | return me;// chainable |
141 | 146 | }; |
142 | 147 |
|
143 | | - me.send = function(aEvt){ |
| 148 | + me.send = function(evt){ |
144 | 149 | if(state != 1){ |
145 | 150 | throw new Error("Session is not in connected state"); |
146 | 151 | } |
147 | | - var payload = me.outCodecChain.transform(aEvt); |
| 152 | + var payload = me.outCodecChain.transform(evt); |
148 | 153 | ws.send( payload ); // <= send JSON/Binary data to socket server |
149 | 154 | return me; |
150 | 155 | }; |
|
170 | 175 | ws.close(); |
171 | 176 | }; |
172 | 177 |
|
173 | | - function dispatch(eventName, message){ |
174 | | - dispatchToEventHandlers(callback[jet.ANY],message); |
175 | | - dispatchToEventHandlers(callbacks[eventName],message); |
| 178 | + function dispatch(eventName, evt){ |
| 179 | + dispatchToEventHandlers(callback[jet.ANY], evt); |
| 180 | + dispatchToEventHandlers(callbacks[eventName], evt); |
176 | 181 | } |
177 | 182 |
|
178 | | - function dispatchToEventHandlers(chain, message){ |
| 183 | + function dispatchToEventHandlers(chain, evt){ |
179 | 184 | if(typeof chain === 'undefined') return; // no callbacks for this event |
180 | 185 | for(var i = 0; i < chain.length; i++){ |
181 | | - chain[i]( message ); |
| 186 | + chain[i]( evt ); |
182 | 187 | } |
183 | 188 | } |
184 | 189 |
|
|
0 commit comments