Idorobots

(define-struct subscriber (on-subscription on-next on-error on-complete))
(define-struct subscription (on-request on-cancel))
(define-struct publisher (on-subscriber on-publish on-error on-complete))

(define (subscription on-request on-cancel)
  (make-subscription on-request on-cancel))

(define (request sub n)
  ((subscription-on-request sub) n))

Idorobots

;; Stream Returning Converter
;; Assumes syntax & macro-expanded code.

(load "compiler/ast.scm")
(load "compiler/utils.scm")

(define (src expr source)
  (cond ((define? expr) (src-define expr source))
        ((lambda? expr) (src-lambda expr source))
        ((if? expr) (src-if expr source))