fixes

lib/src/channel.dart

@@ -278,12 +278,16 @@ class PhoenixChannel {
     );
 
     if (canPush) {
+      _logger.finest(() => 'Sending out push ${pushEvent.ref}');
       pushEvent.send();
     } else {
-      if (_state == PhoenixChannelState.closed) {
-        throw ChannelClosedError('Can\'t push event on a closed channel');
+      if (_state == PhoenixChannelState.closed ||
+          _state == PhoenixChannelState.errored) {
+        throw ChannelClosedError('Can\'t push event on a $_state channel');
       }
 
+      _logger.finest(
+          () => 'Buffering push ${pushEvent.ref} for later send ($_state)');
       pushBuffer.add(pushEvent);
     }
 

lib/src/events.dart

@@ -133,13 +133,15 @@ class PhoenixChannelEvent {
       value.startsWith(__replyEventName);
 
   /// Whether the event name is a 'channel reply' event
-  bool get isChannelReply =>
-      value.startsWith(__chanReplyEventName);
+  bool get isChannelReply => value.startsWith(__chanReplyEventName);
 
   @override
   bool operator ==(Object other) =>
       other is PhoenixChannelEvent && other.value == value;
 
   @override
   int get hashCode => Object.hash(runtimeType, value);
+
+  @override
+  String toString() => 'PhoenixChannelEvent($value)';
 }

lib/src/push.dart

@@ -202,7 +202,7 @@ class Push {
 
     _timeoutTimer ??= Timer(timeout!, () {
       _timeoutTimer = null;
-      _logger.warning('Push $ref timed out');
+      _logger.warning(() => 'Push $ref timed out');
       _channel.trigger(Message.timeoutFor(ref));
     });
   }
@@ -268,6 +268,7 @@ class Push {
   // Remove existing waiters and reset completer
   void cleanUp() {
     if (_sent) {
+      _logger.fine('Cleaning up completer');
       clearReceivers();
       _responseCompleter = Completer();
     }
@@ -279,7 +280,9 @@ class Push {
       if (response.event == replyEvent) {
         trigger(PushResponse.fromMessage(response));
       }
-    } else {
+    } else if (event != PhoenixChannelEvent.join) {
+      _logger.finest(
+          () => "Completing with error: ${_responseCompleter.hashCode}");
       if (!_responseCompleter.isCompleted) {
         _responseCompleter.completeError(response);
         clearReceivers();