1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
| package com.nq.ws.parser;
|
| public interface Parser {
|
| /**
| * Packet type `connect`.
| */
| int CONNECT = 0;
|
| /**
| * Packet type `disconnect`.
| */
| int DISCONNECT = 1;
|
| /**
| * Packet type `event`.
| */
| int EVENT = 2;
|
| /**
| * Packet type `ack`.
| */
| int ACK = 3;
|
| /**
| * Packet type `error`.
| */
| int CONNECT_ERROR = 4;
|
| /**
| * Packet type `binary event`.
| */
| int BINARY_EVENT = 5;
|
| /**
| * Packet type `binary ack`.
| */
| int BINARY_ACK = 6;
|
| int protocol = 5;
|
| /**
| * Packet types.
| */
| String[] types = new String[] {
| "CONNECT",
| "DISCONNECT",
| "EVENT",
| "ACK",
| "ERROR",
| "BINARY_EVENT",
| "BINARY_ACK"
| };
|
| interface Encoder {
|
| void encode(Packet obj, Callback callback);
|
| interface Callback {
|
| void call(Object[] data);
| }
| }
|
| interface Decoder {
|
| void add(String obj);
|
| void add(byte[] obj);
|
| void destroy();
|
| void onDecoded(Callback callback);
|
| interface Callback {
|
| void call(Packet packet);
| }
| }
| }
|
|
