mackuba.eu
A Ruby gem for streaming data from the Bluesky/ATProto firehose
added a base class for errors
+7
-4
+7
-4
lib/skyfall/errors.rb
+7
-4
lib/skyfall/errors.rb
···
1
1
module Skyfall
2
-
class DecodeError < StandardError
2
+
class Error < StandardError
3
3
end
4
4
5
-
class UnsupportedError < StandardError
5
+
class DecodeError < Error
6
+
end
7
+
8
+
class UnsupportedError < Error
6
9
end
7
10
8
-
class ReactorActiveError < StandardError
11
+
class ReactorActiveError < Error
9
12
def initialize
10
13
super(
11
14
"An EventMachine reactor thread is already running, but it seems to have been launched by another Stream. " +
···
14
17
end
15
18
end
16
19
17
-
class SubscriptionError < StandardError
20
+
class SubscriptionError < Error
18
21
attr_reader :error_type, :error_message
19
22
20
23
def initialize(error_type, error_message = nil)