Method: OpenC3::MqttInterface#read

Defined in:
lib/openc3/interfaces/mqtt_interface.rb

#read ⇒ Object 



176
177
178
179
180
181
182
183
184
185
186
187
188
 
# File 'lib/openc3/interfaces/mqtt_interface.rb', line 176

def read
  packet = super()
  topic = @read_topics.shift
  return nil unless packet
  identified_packet = @read_packets_by_topic[topic]
  if identified_packet
    identified_packet = identified_packet.dup
    identified_packet.buffer = packet.buffer
    packet = identified_packet
  end
  packet.received_time = nil
  return packet
end