passing specs

cloudamqp · May 20, 2024 · 8fb27b6 · 8fb27b6
1 parent faf8fa3
commit 8fb27b6
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/spec/replication_spec.cr b/spec/replication_spec.cr
@@ -125,15 +125,15 @@ describe LavinMQ::Replication::Server do
       when done.receive
         fail "Should not receive message"
       when timeout(0.1.seconds)
+        #ugly hack to free us from deadlock
+        repli = LavinMQ::Replication::Client.new(data_dir)
+        done = Channel(Nil).new
+        spawn do
+          repli.follow("127.0.0.1", LavinMQ::Config.instance.replication_port)
+          done.send nil
+        end
+        done.receive
         client.try &.close(no_wait: true)
-        # Ugly hack to free us
-        # repli = LavinMQ::Replication::Client.new(data_dir)
-        # done = Channel(Nil).new
-        # spawn do
-        #   repli.follow("127.0.0.1", LavinMQ::Config.instance.replication_port)
-        #   done.send nil
-        # end
-        # done.receive
       end
     end
   end