mackuba.eu
A Ruby gem for streaming data from the Bluesky/ATProto firehose
moved existing_reactor? to private methods
+4
-4
+4
-4
lib/skyfall/stream.rb
+4
-4
lib/skyfall/stream.rb
···
86
86
end
87
87
end
88
88
89
-
def existing_reactor?
90
-
EM.reactor_running? && !@engines_on
91
-
end
92
-
93
89
def handle_message(msg)
94
90
data = msg.data
95
91
@handlers[:raw_message]&.call(data)
···
186
182
187
183
188
184
private
185
+
186
+
def existing_reactor?
187
+
EM.reactor_running? && !@engines_on
188
+
end
189
189
190
190
def reconnect_delay
191
191
if @connection_attempts == 0