mackuba.eu / skyfall
A Ruby gem for streaming data from the Bluesky/ATProto firehose
fork atom

added Message#unknown? helper

mackuba.eu cfba9fe2 892b3c42

+8
+4
lib/skyfall/firehose/message.rb
··· 56 56 [] 57 57 end 58 58 59 + def unknown? 60 + self.is_a?(Firehose::UnknownMessage) 61 + end 62 + 59 63 def time 60 64 @time ||= @data_object['time'] && Time.parse(@data_object['time']) 61 65 end
+4
lib/skyfall/jetstream/message.rb
··· 39 39 @time_us = @json['time_us'] 40 40 end 41 41 42 + def unknown? 43 + self.is_a?(Jetstream::UnknownMessage) 44 + end 45 + 42 46 def operations 43 47 [] 44 48 end