From 60b24fa1ae9e461cabbe9c4705e7ffa268a56014 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Fri, 20 Oct 2017 10:58:31 +0800
Subject: [PATCH]

---
 src/org/redkale/net/http/WebSocketEngine.java | 2 +-
 src/org/redkale/net/http/WebSocketNode.java   | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/org/redkale/net/http/WebSocketEngine.java b/src/org/redkale/net/http/WebSocketEngine.java
index 13cb56553..e0c4716e3 100644
--- a/src/org/redkale/net/http/WebSocketEngine.java
+++ b/src/org/redkale/net/http/WebSocketEngine.java
@@ -202,7 +202,7 @@ public class WebSocketEngine {
     }
 
     @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();
         Serializable[] ss = new Serializable[array.length];
         for (int i = 0; i < array.length; i++) {
diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java
index 1fb2906df..524e7255c 100644
--- a/src/org/redkale/net/http/WebSocketNode.java
+++ b/src/org/redkale/net/http/WebSocketNode.java
@@ -232,7 +232,7 @@ public abstract class WebSocketNode {
      *
      * @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);
     }
 
@@ -259,7 +259,7 @@ public abstract class WebSocketNode {
      *
      * @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);
     }
 
@@ -287,7 +287,7 @@ public abstract class WebSocketNode {
      *
      * @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);
     }
 
@@ -316,7 +316,7 @@ public abstract class WebSocketNode {
      *
      * @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();
         Serializable[] ss = new Serializable[array.length];
         for (int i = 0; i < array.length; i++) {