: unpublish ( id -- )
remote-channels delete-at ;
-
+
<PRIVATE
MATCH-VARS: ?from ?tag ?id ?value ;
: start-channel-node ( -- )
"remote-channels" get-remote-thread [
[ channel-thread t ] "Remote channels" spawn-server
- "remote-channels" register-remote-thread
+ "remote-channels" register-remote-thread
] unless ;
PRIVATE>
TUPLE: remote-channel node id ;
-C: <remote-channel> remote-channel
+C: <remote-channel> remote-channel
<PRIVATE
: send-message ( message remote-channel -- value )
- node>> "remote-channels" <remote-thread>
+ node>> "remote-channels" <remote-thread>
send-synchronous dup no-channel = [ no-channel throw ] when* ;
-
+
PRIVATE>
M: remote-channel to ( value remote-channel -- )