diff --git a/lib/worker/master.rb b/lib/worker/master.rb index a059443..56eae6e 100644 --- a/lib/worker/master.rb +++ b/lib/worker/master.rb @@ -35,7 +35,6 @@ def fetch fetch_active_accounts!.map do |account_hash| Thread.new do fetch_trades_for_account!(account_hash) - Thread.current.exit end end.map(&:join) end @@ -47,7 +46,6 @@ def check_for_history_request fetch_active_accounts!.map do |account_hash| Thread.new do CmeFixListener::HistoryRequestClient.new(account_hash).history_request! - Thread.current.exit end end.map(&:join)