From 5228b41f2e864303d524c385587db5266a2742e8 Mon Sep 17 00:00:00 2001 From: tkuchiki Date: Mon, 24 Aug 2020 21:53:19 +0900 Subject: [PATCH] patch #85 --- fetcher.go | 4 ++-- manager.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/fetcher.go b/fetcher.go index 9a34134..04ff0a4 100644 --- a/fetcher.go +++ b/fetcher.go @@ -60,7 +60,7 @@ func (f *fetch) Fetch() { for { // f.Close() has been called if f.Closed() { - break + return } <-f.Ready() f.tryFetchMessage() @@ -74,7 +74,7 @@ func (f *fetch) Fetch() { close(f.closed) // Signal to Close() that the fetcher has stopped close(f.exit) - break + return } } } diff --git a/manager.go b/manager.go index 0e4ee6f..7550546 100644 --- a/manager.go +++ b/manager.go @@ -60,7 +60,7 @@ func (m *manager) manage() { m.fetch.Acknowledge(message) case <-m.stop: m.exit <- true - break + return } } }