http-getから入力ポートをつくりだすための試験場

t.scm

(use rfc.http)
(use gauche.generator)
(use util.stream)

(define (http-hook-receiver proc) 
  (lambda (code hdrs total retr)
    (let loop [ ]
      (receive (port size) (retr) 
        (cond
          [ (eqv? size 0) #t]
          [ (or (not size) (> size 0) )
           (let loop-rb [(data (read-block size port) ) 
                         (req-size  size) ]
             (proc data) ; hook
             (let1 nrest (- req-size (string-length data))
               (if (= nrest 0)
                 (loop)
                 (loop-rb (read-block nrest port) nrest ) ) ) ) ]
          ) ) ) ) )

(define (http-get-stream host path)
    (iterator->stream 
      (^ (next end)
        (http-get host path 
                  :receiver (http-hook-receiver next) ) 
        (end)
        ) ) )


(define (main args)
  ;(http-get "www.google.com" "/" :receiver (http-hook-receiver (^p (debug-print p) )) ) (exit)

  (stream-for-each 
    (^q (debug-print q) )                
    (http-get-stream "www.google.com" "/")))