/
AckRequest.java
90 lines (81 loc) · 2.83 KB
/
AckRequest.java
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
81
82
83
84
85
86
87
88
89
90
/**
* Copyright (c) 2012-2023 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.corundumstudio.socketio;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import com.corundumstudio.socketio.listener.DataListener;
import com.corundumstudio.socketio.protocol.Packet;
import com.corundumstudio.socketio.protocol.PacketType;
/**
* Ack request received from Socket.IO client.
* You can always check is it <code>true</code> through
* {@link #isAckRequested()} method.
*
* You can call {@link #sendAckData} methods only during
* {@link DataListener#onData} invocation. If {@link #sendAckData}
* not called it will be invoked with empty arguments right after
* {@link DataListener#onData} method execution by server.
*
* This object is NOT actual anymore if {@link #sendAckData} was
* executed or {@link DataListener#onData} invocation finished.
*
*/
public class AckRequest {
private final Packet originalPacket;
private final SocketIOClient client;
private final AtomicBoolean sended = new AtomicBoolean();
public AckRequest(Packet originalPacket, SocketIOClient client) {
this.originalPacket = originalPacket;
this.client = client;
}
/**
* Check whether ack request was made
*
* @return true if ack requested by client
*/
public boolean isAckRequested() {
return originalPacket.isAckRequested();
}
/**
* Send ack data to client.
* Can be invoked only once during {@link DataListener#onData}
* method invocation.
*
* @param objs - ack data objects
*/
public void sendAckData(Object ... objs) {
List<Object> args = Arrays.asList(objs);
sendAckData(args);
}
/**
* Send ack data to client.
* Can be invoked only once during {@link DataListener#onData}
* method invocation.
*
* @param objs - ack data object list
*/
public void sendAckData(List<Object> objs) {
if (!isAckRequested() || !sended.compareAndSet(false, true)) {
return;
}
Packet ackPacket = new Packet(PacketType.MESSAGE, client.getEngineIOVersion());
ackPacket.setSubType(PacketType.ACK);
ackPacket.setAckId(originalPacket.getAckId());
ackPacket.setData(objs);
client.send(ackPacket);
}
}