Skip to content

Commit fb8be77

Browse files
committed
fix for can not work broadcast by RedisGroup #252
1 parent a2e19b3 commit fb8be77

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/MagicOnion.Redis/RedisGroup.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
using MagicOnion.Server;
1+
using MagicOnion.Server;
22
using MagicOnion.Server.Hubs;
33
using MagicOnion.Utils;
44
using MessagePack;
@@ -129,13 +129,13 @@ static Task PublishFromRedisToMemoryGroup(RedisValue value, IGroup group)
129129
{
130130
var excludes = NativeGuidArrayFormatter.Deserialize(ref reader);
131131
var offset = (int)reader.Consumed;
132-
return group.WriteExceptRawAsync(new ArraySegment<byte>(buffer, offset, buffer.Length - offset), excludes, fireAndForget: false);
132+
return group.WriteExceptRawAsync(new ArraySegment<byte>(buffer, offset, buffer.Length - offset), excludes, fireAndForget: true);
133133
}
134134
else
135135
{
136136
var includes = NativeGuidArrayFormatter.Deserialize(ref reader);
137137
var offset = (int)reader.Consumed;
138-
return group.WriteToRawAsync(new ArraySegment<byte>(buffer, offset, buffer.Length - offset), includes, fireAndForget: false);
138+
return group.WriteToRawAsync(new ArraySegment<byte>(buffer, offset, buffer.Length - offset), includes, fireAndForget: true);
139139
}
140140
}
141141

0 commit comments

Comments
 (0)