Liking cljdoc? Tell your friends :D

com.blockether.vis.internal.python.worker-peer

Host-side client of the runtime worker's JSON-line protocol. Dispatch and cancellation stay in Vis; interpreter operations live in the runtime.

Host-side client of the runtime worker's JSON-line protocol.
Dispatch and cancellation stay in Vis; interpreter operations live in the runtime.
raw docstring

claim-reply!clj

(claim-reply! peer id)

True exactly once per served request id: whoever answers it first — the tool that finished, or the interrupt that failed it — is the only answer the child ever reads. A late answer for an id already claimed is dropped here, never sent.

True exactly once per served request `id`: whoever answers it first — the tool
that finished, or the interrupt that failed it — is the only answer the child
ever reads. A late answer for an id already claimed is dropped here, never sent.
sourceraw docstring

peer-overclj

(peer-over channel)

A peer over channel: what to read, what to write, who is waiting for a reply, and which of the peer's requests this side is still serving.

A peer over `channel`: what to read, what to write, who is waiting for a
reply, and which of the peer's requests this side is still serving.
sourceraw docstring

pump!clj

(pump! peer serve reason)

Read this peer until it closes: a reply settles whoever waits for it, a request goes to serve on a thread of its own — serving inline would stall the pump behind a call that is itself waiting on this peer.

On close every pending call fails with reason, because a caller parked on a child that has died would otherwise wait forever.

Read this peer until it closes: a reply settles whoever waits for it, a
request goes to `serve` on a thread of its own — serving inline would stall
the pump behind a call that is itself waiting on this peer.

On close every pending call fails with `reason`, because a caller parked on a
child that has died would otherwise wait forever.
sourceraw docstring

request!clj

(request! peer message)
(request! peer message timeout-ms)

Ask the peer message and answer its reply value; its error throws here. timeout-ms bounds CONTROL messages only; ordinary work waits for its real result. Pending replies survive caller cancellation until the child replies or closes, so cancellation can still watch the actual guest execution.

Ask the peer `message` and answer its reply value; its error throws here.
`timeout-ms` bounds CONTROL messages only; ordinary work waits for its real
result. Pending replies survive caller cancellation until the child replies
or closes, so cancellation can still watch the actual guest execution.
sourceraw docstring

rpc-snapshotclj

(rpc-snapshot peer)

Payload-free last completions and active calls in both directions, including active caller stacks (also virtual threads). At most 64 calls and frames per direction. Cancellation does not remove a request still owed a real guest reply.

Payload-free last completions and active calls in both directions, including
active caller stacks (also virtual threads). At most 64 calls and frames per direction.
Cancellation does not remove a request still owed a real guest reply.
sourceraw docstring

send-line!clj

(send-line! peer message)

Write one message on the peer's write thread and wait until it is written. The single thread keeps each line whole. An interrupt does not stop the wait: a closed channel ends the write, and the interrupt stays set for the caller.

Write one message on the peer's write thread and wait until it is written.
The single thread keeps each line whole. An interrupt does not stop the wait:
a closed channel ends the write, and the interrupt stays set for the caller.
sourceraw docstring

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
× close