queue-timeout ( queue timeout -- timer )

Vocabulary

concurrency.conditions

Inputs

queue	an object
timeout	an object

Outputs

timer

an object

Definition

USING: deques kernel threads timers ;

IN: concurrency.conditions

: queue-timeout ( queue timeout -- timer )
    [
        [ self swap push-front* ] keep '[
            _ _ [ delete-node ] [ drop node-value ] 2bi
            t swap resume-with
        ]
    ] dip remaining-timeout later ;