Exception: Featureflip::DataSource::StreamingHandler::StreamStopped

Inherits:
Exception
  • Object
show all
Defined in:
lib/featureflip/data_source/streaming.rb

Overview

Raised into the streaming thread by #stop to interrupt a blocking read (Thread#wakeup only wakes a sleeping thread; it can't interrupt an MRI IO read — Thread#raise can). Inherits from Exception, not StandardError, so it bypasses handle_event's/run's generic rescue StandardError arms (which would otherwise swallow a stop mid-event and leave the thread blocking) and is only caught by the explicit rescue StreamStopped.