def create_processing_thread
      @processing_thread = Thread.new do
        Thread.current.abort_on_exception = true

        loop { break unless processing_thread_tick @stream_connection.read_line }

        @processing_thread = @stream_connection = nil
      end
    end
def create_processing_thread
      @processing_thread = Thread.new do
        Thread.current.abort_on_exception = true

        loop { break unless processing_thread_tick @stream_connection.read_line }

        @processing_thread = @stream_connection = nil
      end
    end
Starts the processing thread that reads and processes incoming data from the stream connection.