in lib/aws-xray-sdk/recorder.rb [88:107]
def end_subsegment(end_time: nil)
entity = current_entity
return unless entity.is_a?(Subsegment)
entity.close end_time: end_time
if entity.parent.closed?
context.clear!
else
context.store_entity entity: entity.parent
end
segment = entity.segment
if segment.ready_to_send?
emitter.send_entity entity: segment
elsif streamer.eligible? segment: segment
streamer.stream_subsegments root: segment, emitter: emitter
end
end