wulin/qiuguo-iot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BaseSession使用安全list

Browse Source
This commit is contained in:
wulin 2023-11-22 14:54:52 +08:00
parent 2bd1d6815b
commit 166f2db0a0
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java
View File

@ -6,6 +6,8 @@ import lombok.Data;
import org.springframework.web.reactive.socket.WebSocketMessage; import org.springframework.web.reactive.socket.WebSocketMessage;
import org.springframework.web.reactive.socket.WebSocketSession; import org.springframework.web.reactive.socket.WebSocketSession;
import reactor.core.publisher.FluxSink; import reactor.core.publisher.FluxSink;
import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.ArrayList; import java.util.ArrayList;
@ -82,6 +84,7 @@ public class BaseSession {
/** /**
* 临时记录发送给客户端resp * 临时记录发送给客户端resp
* 语音合成时使用
*/ */
List<BaseMessageResp> respList = new ArrayList<>(10); List<BaseMessageResp> respList = Collections.synchronizedList(new ArrayList<>(10));
} }