gen.process — actors/gen 0.1.0-SNAPSHOT

*print-state* clj

*stacktrace-max-length* clj

*stacktraces* clj

add-links clj

(add-links process links)

add-to-linker clj

(add-to-linker process)

(add-to-linker process linker)

alive? clj

(alive? process)

create clj

(create &
        {:keys [name thread start stop-timeout message-queue linker links
                return-promise stop-promise state-getter receive-promise-queue
                type]
         :or {type :default
              message-queue (clojure.lang.PersistentQueue/EMPTY)
              receive-promise-queue (clojure.lang.PersistentQueue/EMPTY)
              links #{}
              stop-timeout 500
              start (fn [process args stop-promise] nil)}})

get-links clj

(get-links process)

get-thread clj

(get-thread process)

have-dead-links clj

(have-dead-links process)

kill clj

(kill process)

message clj

(message to message#)

(message from to message)

If no FROM message, attempt to lookup your process in default linker-storage by your thread. If it's not there, from is nil.

message-internal clj

(message-internal process message)

process? clj

(process? arg)

queue-empty? clj

(queue-empty? process)

queue-flush clj

(queue-flush process)

queue-pop clj

(queue-pop process)

queue-size clj

(queue-size process)

queue-top clj

(queue-top process)

receive clj macro

(receive [variable process] BODY)

(receive [variable process] TRUE-BODY FALSE-BODY)

VARIABLE is variable, which will hold message(or promise, see below). If FALSE-BODY is given, execute TRUE-BODY only if message was received now, otherwise execute FALSE-BODY. If FALSE-BODY is not given, variable will hold promise, that will hold message, when it will be received. Use deref.

restart clj

(restart process reason args)

restart-link clj

(restart-link process reason args)

result-of clj

(result-of process)

self clj

(self & {:keys [storage] :or {storage gen.linker-storage/*linker*}})

set-links clj

(set-links process links)

stacktrace-of clj

(stacktrace-of process & [max-length])

start clj

(start process args)

start-link clj

(start-link process args)

state-of clj

(state-of process)

stop clj

(stop process reason)

to-string clj

(to-string process)