lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-10-20 10:58:31 +08:00
parent b784993110
commit 60b24fa1ae
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/net/http/WebSocketEngine.java
View File

@@ -202,7 +202,7 @@ public class WebSocketEngine {
} }
@Comment("给指定用户组发送消息") @Comment("给指定用户组发送消息")
public CompletableFuture<Integer> sendMessage(final Object message, final boolean last, final Stream<Serializable> userids) { public CompletableFuture<Integer> sendMessage(final Object message, final boolean last, final Stream<? extends Serializable> userids) {
Object[] array = userids.toArray(); Object[] array = userids.toArray();
Serializable[] ss = new Serializable[array.length]; Serializable[] ss = new Serializable[array.length];
for (int i = 0; i < array.length; i++) { for (int i = 0; i < array.length; i++) {

8
src/org/redkale/net/http/WebSocketNode.java
View File

@@ -232,7 +232,7 @@ public abstract class WebSocketNode {
* *
* @return 为0表示成功， 其他值表示部分发送异常 * @return 为0表示成功， 其他值表示部分发送异常
*/ */
public final CompletableFuture<Integer> sendMessage(Object message, final Stream<Serializable> userids) { public final CompletableFuture<Integer> sendMessage(Object message, final Stream<? extends Serializable> userids) {
return sendMessage((Convert) null, message, true, userids); return sendMessage((Convert) null, message, true, userids);
} }
@@ -259,7 +259,7 @@ public abstract class WebSocketNode {
* *
* @return 为0表示成功， 其他值表示部分发送异常 * @return 为0表示成功， 其他值表示部分发送异常
*/ */
public final CompletableFuture<Integer> sendMessage(final Convert convert, Object message, final Stream<Serializable> userids) { public final CompletableFuture<Integer> sendMessage(final Convert convert, Object message, final Stream<? extends Serializable> userids) {
return sendMessage(convert, message, true, userids); return sendMessage(convert, message, true, userids);
} }
@@ -287,7 +287,7 @@ public abstract class WebSocketNode {
* *
* @return 为0表示成功， 其他值表示部分发送异常 * @return 为0表示成功， 其他值表示部分发送异常
*/ */
public final CompletableFuture<Integer> sendMessage(final Object message, final boolean last, final Stream<Serializable> userids) { public final CompletableFuture<Integer> sendMessage(final Object message, final boolean last, final Stream<? extends Serializable> userids) {
return sendMessage((Convert) null, message, last, userids); return sendMessage((Convert) null, message, last, userids);
} }
@@ -316,7 +316,7 @@ public abstract class WebSocketNode {
* *
* @return 为0表示成功， 其他值表示部分发送异常 * @return 为0表示成功， 其他值表示部分发送异常
*/ */
public final CompletableFuture<Integer> sendMessage(final Convert convert, final Object message0, final boolean last, final Stream<Serializable> userids) { public final CompletableFuture<Integer> sendMessage(final Convert convert, final Object message0, final boolean last, final Stream<? extends Serializable> userids) {
Object[] array = userids.toArray(); Object[] array = userids.toArray();
Serializable[] ss = new Serializable[array.length]; Serializable[] ss = new Serializable[array.length];
for (int i = 0; i < array.length; i++) { for (int i = 0; i < array.length; i++) {