anchor.diff:    (assert (member filter-level '(:NONE :LOW :MEDIUM)) () "FILTER-LEVEL must be one of (:NONE :LOW :MEDIUM).")
     (when count (assert (< -150000 count 150000) () "COUNT must be NIL or between -150000 and 150000."))
     (when language (assert (valid-language-p language) () "~a is not a supported language." language))
  -  (let ((stream (signed-stream-request *stream/statuses/sample* :parameters (prepare* stall-warnings filter-level language count) :method :GET)))
  -    (unwind-protect
  -         (loop for line = (read-line stream)
  -               for object = (parse-stream-line (trim-whitespace line))
  -               while (funcall handler-function object))
  -      (close stream))))
  +  (process-stream-inner (signed-stream-request *stream/statuses/sample* :parameters (prepare* stall-warnings filter-level language count) :method :GET
  +                                                                        :drakma-params (list :force-binary T))
  +                        handler-function))
   
   (defun stream/statuses/firehose (handler-function &key stall-warnings (filter-level :NONE) language count)
     "Returns all public statuses. Few applications require this level of access. Creative use of a combination of other resources and various access levels can satisfy nearly every application use case.
  
positive.code: (defun trim-whitespace (string)
    (string-trim '(#\Tab #\Newline #\Linefeed #\Page #\Return #\Space) string))
  
  (defun stream/user (handler-function &key stall-warnings (filter-level :NONE) language (with :USER) replies count)
    "Streams messages for a single user, as described in User streams.
  Each line is parsed into an appropriate object (NIL for empty lines) and passed to the handler function.
  
negative.code:   (when count (assert (< -150000 count 150000) () "COUNT must be NIL or between -150000 and 150000."))
    (when language (assert (valid-language-p language) () "~a is not a supported language." language))
    (when replies (setf replies "all"))
    (process-stream-inner (signed-stream-request *stream/user* :parameters (prepare* stall-warnings filter-level language with replies count) :method :GET
                                                 :drakma-params (list :force-binary T))
                          handler-function))
  
  (defun stream/site (handler-function follow &key stall-warnings (filter-level :NONE) language (with :FOLLOW) replies count)
    "Streams messages for a set of users, as described in Site streams.
  