tangled
alpha
login
or
join now
mackuba.eu
/
skyfall
6
fork
atom
A Ruby gem for streaming data from the Bluesky/ATProto firehose
6
fork
atom
overview
issues
pulls
pipelines
moved inspectable_variables to private or protected
mackuba.eu
2 months ago
54131daa
11185828
+26
-15
5 changed files
expand all
collapse all
unified
split
lib
skyfall
firehose
info_message.rb
message.rb
operation.rb
jetstream
operation.rb
stream.rb
+2
lib/skyfall/firehose/info_message.rb
···
17
17
(@name || "InfoMessage") + (@message ? ": #{@message}" : "")
18
18
end
19
19
20
20
+
protected
21
21
+
20
22
def inspectable_variables
21
23
super - [:@did, :@seq]
22
24
end
+8
-4
lib/skyfall/firehose/message.rb
···
62
62
@time ||= @data_object['time'] && Time.parse(@data_object['time'])
63
63
end
64
64
65
65
-
def inspectable_variables
66
66
-
instance_variables - [:@type_object, :@data_object, :@blocks]
67
67
-
end
68
68
-
69
65
def inspect
70
66
vars = inspectable_variables.map { |v| "#{v}=#{instance_variable_get(v).inspect}" }.join(", ")
71
67
"#<#{self.class}:0x#{object_id} #{vars}>"
72
68
end
69
69
+
70
70
+
71
71
+
protected
72
72
+
73
73
+
def inspectable_variables
74
74
+
instance_variables - [:@type_object, :@data_object, :@blocks]
75
75
+
end
76
76
+
73
77
74
78
private
75
79
+6
-4
lib/skyfall/firehose/operation.rb
···
46
46
Collection.short_code(collection)
47
47
end
48
48
49
49
-
def inspectable_variables
50
50
-
instance_variables - [:@message]
51
51
-
end
52
52
-
53
49
def inspect
54
50
vars = inspectable_variables.map { |v| "#{v}=#{instance_variable_get(v).inspect}" }.join(", ")
55
51
"#<#{self.class}:0x#{object_id} #{vars}>"
52
52
+
end
53
53
+
54
54
+
private
55
55
+
56
56
+
def inspectable_variables
57
57
+
instance_variables - [:@message]
56
58
end
57
59
end
58
60
end
+6
-4
lib/skyfall/jetstream/operation.rb
···
46
46
Collection.short_code(collection)
47
47
end
48
48
49
49
-
def inspectable_variables
50
50
-
instance_variables - [:@message]
51
51
-
end
52
52
-
53
49
def inspect
54
50
vars = inspectable_variables.map { |v| "#{v}=#{instance_variable_get(v).inspect}" }.join(", ")
55
51
"#<#{self.class}:0x#{object_id} #{vars}>"
52
52
+
end
53
53
+
54
54
+
private
55
55
+
56
56
+
def inspectable_variables
57
57
+
instance_variables - [:@message]
56
58
end
57
59
end
58
60
end
+4
-3
lib/skyfall/stream.rb
···
156
156
end
157
157
end
158
158
159
159
-
def inspectable_variables
160
160
-
instance_variables - [:@handlers, :@ws]
161
161
-
end
162
159
163
160
def inspect
164
161
vars = inspectable_variables.map { |v| "#{v}=#{instance_variable_get(v).inspect}" }.join(", ")
···
178
175
179
176
def send_data(data)
180
177
@ws.send(data)
178
178
+
end
179
179
+
180
180
+
def inspectable_variables
181
181
+
instance_variables - [:@handlers, :@ws]
181
182
end
182
183
183
184