X-Git-Url: https://jxself.org/git/?a=blobdiff_plain;f=8sync%2Finbox.scm;fp=8sync%2Finbox.scm;h=28e2c79d4fb56d330c5df202f4728a3b9de49f71;hb=5f12e17b62324e34e5e81a1c2a21a46edc988705;hp=bf1eabc1a3fb8a9c3607e01384b3bfdd63c0b46b;hpb=67f40c6246d3f83a64bcc5ffbe884752c003ded9;p=8sync.git diff --git a/8sync/inbox.scm b/8sync/inbox.scm index bf1eabc..28e2c79 100644 --- a/8sync/inbox.scm +++ b/8sync/inbox.scm @@ -27,6 +27,7 @@ #:use-module (ice-9 atomic) #:export (delivery-agent)) +;; TODO: Add backpressure limit (define (delivery-agent inbox-enq inbox-deq stop?) "This starts up a loop doing delivery receiving from INBOX-ENQ and delivering to INBOX-DEQ, actually managing an (ice-9 q) object QUEUE.