MCPcopy
hub / github.com/socketio/socket.io-client-java / onpacket

Method onpacket

src/main/java/io/socket/client/Socket.java:302–343  ·  view source on GitHub ↗
(Packet<?> packet)

Source from the content-addressed store, hash-verified

300 }
301
302 private void onpacket(Packet<?> packet) {
303 if (!this.nsp.equals(packet.nsp)) return;
304
305 switch (packet.type) {
306 case Parser.CONNECT: {
307 if (packet.data instanceof JSONObject && ((JSONObject) packet.data).has("sid")) {
308 try {
309 this.onconnect(((JSONObject) packet.data).getString("sid"));
310 return;
311 } catch (JSONException e) {}
312 } else {
313 super.emit(EVENT_CONNECT_ERROR, new SocketIOException("It seems you are trying to reach a Socket.IO server in v2.x with a v3.x client, which is not possible"));
314 }
315 break;
316 }
317
318 case Parser.EVENT:
319 case Parser.BINARY_EVENT: {
320 @SuppressWarnings("unchecked")
321 Packet<JSONArray> p = (Packet<JSONArray>) packet;
322 this.onevent(p);
323 break;
324 }
325
326 case Parser.ACK:
327 case Parser.BINARY_ACK: {
328 @SuppressWarnings("unchecked")
329 Packet<JSONArray> p = (Packet<JSONArray>) packet;
330 this.onack(p);
331 break;
332 }
333
334 case Parser.DISCONNECT:
335 this.ondisconnect();
336 break;
337
338 case Parser.CONNECT_ERROR:
339 this.destroy();
340 super.emit(EVENT_CONNECT_ERROR, packet.data);
341 break;
342 }
343 }
344
345 private void onevent(Packet<JSONArray> packet) {
346 List<Object> args = new ArrayList<>(Arrays.asList(toArray(packet.data)));

Callers 1

callMethod · 0.80

Calls 6

onconnectMethod · 0.95
oneventMethod · 0.95
onackMethod · 0.95
ondisconnectMethod · 0.95
destroyMethod · 0.95
emitMethod · 0.80

Tested by

no test coverage detected