summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
cef48f4)
* 8sync/agenda.scm (8sync-nowait, 8sync): Renamed 8sync-nowait to 8sync.
* 8sync/systems/actors.scm (send-message, reply-message hive-reply-with-error):
Switch calls of 8sync-nowait to 8sync.
8sync-delay
8sync-run 8sync-run-at 8sync-run-delay
8sync-delay
8sync-run 8sync-run-at 8sync-run-delay
8sleep
;; used for introspecting the error, but a method for making
8sleep
;; used for introspecting the error, but a method for making
;; TODO: Write (%run-immediately)
;; TODO: Write (%run-immediately)
-(define-syntax-rule (8sync-nowait body)
+(define-syntax-rule (8sync body)
"Run body asynchronously but ignore its result...
forge ahead in our current function!"
(8sync-abort-to-prompt
"Run body asynchronously but ignore its result...
forge ahead in our current function!"
(8sync-abort-to-prompt
(message (make-message (hive-gen-message-id hive) to-id
(actor-id from-actor) action
(kwarg-list-to-alist message-body-args))))
(message (make-message (hive-gen-message-id hive) to-id
(actor-id from-actor) action
(kwarg-list-to-alist message-body-args))))
- (8sync-nowait (hive-process-message hive message))))
+ (8sync (hive-process-message hive message))))
(define (send-message-wait from-actor to-id action . message-body-args)
"Send a message from an actor to another, but wait until we get a response"
(define (send-message-wait from-actor to-id action . message-body-args)
"Send a message from an actor to another, but wait until we get a response"
(actor-id from-actor) '*reply*
(kwarg-list-to-alist message-body-args)
#:in-reply-to (message-id original-message))))
(actor-id from-actor) '*reply*
(kwarg-list-to-alist message-body-args)
#:in-reply-to (message-id original-message))))
- (8sync-nowait (hive-process-message hive new-message))))
+ (8sync (hive-process-message hive new-message))))
(define (reply-message-wait from-actor original-message
. message-body-args)
(define (reply-message-wait from-actor original-message
. message-body-args)
(actor-id hive) '*error*
new-message-body
#:in-reply-to (message-id original-message))))
(actor-id hive) '*error*
new-message-body
#:in-reply-to (message-id original-message))))
- (8sync-nowait (hive-process-message hive new-message))))
+ (8sync (hive-process-message hive new-message))))
(define-method (hive-process-message (hive <hive>) message)
"Handle one message, or forward it via an ambassador"
(define-method (hive-process-message (hive <hive>) message)
"Handle one message, or forward it via an ambassador"