                 res.end()
                 rstream?.destroy() if rstream?.readable
 
-
+    #----------
 
     loadPreroll: (key, req, cb) ->
         count = req.count

        # Pass along any query string to Preroller
        query = qs.stringify(req.query)

        opts =
            host: @options.preroll.server
            path: [

        conn_pre_abort = =>
            debug "#{count}: conn_pre_abort called. Destroyed? ", conn.destroyed

            if !aborted
                debug "#{count}: Aborting preroll"
                req.abort()
                aborted = true

            clearTimeout req_t

        # we don't need to fire the callback after these
        conn.once "close", conn_pre_abort
        conn.once "end", conn_pre_abort

