We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a33edf3 commit b92fe8aCopy full SHA for b92fe8a
lib/src/socket.dart
@@ -498,11 +498,8 @@ class PhoenixSocket {
498
Message _heartbeatMessage() => Message.heartbeat(_nextHeartbeatRef = nextRef);
499
500
void _onMessage(Message message) {
501
+ _nextHeartbeatRef = null;
502
if (message.ref != null) {
- if (_nextHeartbeatRef == message.ref) {
503
- _nextHeartbeatRef = null;
504
- }
505
-
506
final completer = _pendingMessages[message.ref!];
507
if (completer != null) {
508
_pendingMessages.remove(message.ref);
0 commit comments