X-Git-Url: https://jxself.org/git/?p=8sync.git;a=blobdiff_plain;f=8sync%2Finbox.scm;h=fbf8df08222310dfd2b74c4d6c8a088f9b54d62e;hp=28e2c79d4fb56d330c5df202f4728a3b9de49f71;hb=refs%2Fheads%2Ffibers;hpb=7972787723d08a491379b63e6e5dc1cc6a3fac87 diff --git a/8sync/inbox.scm b/8sync/inbox.scm index 28e2c79..fbf8df0 100644 --- a/8sync/inbox.scm +++ b/8sync/inbox.scm @@ -30,8 +30,9 @@ ;; 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. -Atomic box STOP? can be set to indicate that this " +delivering to INBOX-DEQ, actually managing an internal object QUEUE. +Condidtion variable STOP? can be set to indicate that this agent +should stop." (define queue (make-q)) (define get-or-stop