From cae46556e30dacf49bb02a511e37ea03041dcaa0 Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Mon, 27 May 2024 14:47:44 +0200 Subject: [PATCH] revert commit 1de4c18cf6936250d7bd469b1513296386cc72fc --- spec/replication_spec.cr | 1 - src/lavinmq/replication/server.cr | 1 - 2 files changed, 2 deletions(-) diff --git a/spec/replication_spec.cr b/spec/replication_spec.cr index a5983de21..e3851c52d 100644 --- a/spec/replication_spec.cr +++ b/spec/replication_spec.cr @@ -41,7 +41,6 @@ describe LavinMQ::Replication::Client do repli.follow("127.0.0.1", LavinMQ::Config.instance.replication_port) done.send nil end - wait_for { Server.followers.size == 1 } with_channel do |ch| q = ch.queue("repli") q.publish_confirm "hello world" diff --git a/src/lavinmq/replication/server.cr b/src/lavinmq/replication/server.cr index 5f06ee957..c285631f9 100644 --- a/src/lavinmq/replication/server.cr +++ b/src/lavinmq/replication/server.cr @@ -54,7 +54,6 @@ module LavinMQ end def append(path : String, file : MFile, position : Int32, length : Int32) - return if @followers.empty? append path, FileRange.new(file, position, length) end