pump-loop ( -- )

Vocabulary

io.monitors.recursive

Inputs

None

Outputs

None

Definition

USING: combinators concurrency.messaging continuations
io.monitors.private kernel ;

IN: io.monitors.recursive

: pump-loop ( -- )
    receive {
        { [ dup +stop+ eq? ] [ drop stop-pump ] }
        { [ dup monitor-disposed eq? ] [ drop ] }
        [
            [ [ update-hierarchy ] curry ignore-errors ]
            [ pump-step ] bi pump-loop
        ]
    } cond ;