Skip to content

Commit cbac1cd

Browse files
committed
fixed reference to users, avoid spinning multiple timers
1 parent fdf93b7 commit cbac1cd

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/chirpstream.rb

+2-2
Original file line numberDiff line numberDiff line change
@@ -101,8 +101,8 @@ def connect(*users)
101101
EM.run { connect(*users) }
102102
else
103103
@users.concat(users)
104-
EM.add_periodic_timer(1) {
105-
users_to_connect = users.slice!(0, 10)
104+
@user_adder ||= EM.add_periodic_timer(1) {
105+
users_to_connect = @users.slice!(0, 10)
106106
if users_to_connect && !users_to_connect.empty?
107107
users_to_connect.each do |user|
108108
connect_single(user)

0 commit comments

Comments
 (0)