channel-thread ( -- )

Vocabulary

channels.remote.private

Inputs

None

Outputs

None

Definition

USING: channels channels.remote concurrency.messaging kernel
match ;

IN: channels.remote.private

: channel-thread ( -- )
    [
        {
            {
                T{ to-message { id ?id } { value ?value } }
                [
                    ?value ?id get-channel
                    [ to f ] [ drop no-channel ] if*
                ]
            }
            {
                T{ from-message { id ?id } }
                [ ?id get-channel [ from ] [ no-channel ] if* ]
            }
        } match-cond
    ] handle-synchronous ;