1 ! Copyright (C) 2008 Slava Pestov.
2 ! See http://factorcode.org/license.txt for BSD license.
3 USING: kernel accessors assocs sequences threads ;
4 IN: io.backend.unix.multiplexers
6 TUPLE: mx fd reads writes ;
8 : new-mx ( class -- obj )
11 H{ } clone >>writes ; inline
13 GENERIC: add-input-callback ( thread fd mx -- )
15 M: mx add-input-callback reads>> push-at ;
17 GENERIC: add-output-callback ( thread fd mx -- )
19 M: mx add-output-callback writes>> push-at ;
21 GENERIC: remove-input-callbacks ( fd mx -- callbacks )
23 M: mx remove-input-callbacks reads>> delete-at* drop ;
25 GENERIC: remove-output-callbacks ( fd mx -- callbacks )
27 M: mx remove-output-callbacks writes>> delete-at* drop ;
29 GENERIC: wait-for-events ( ms mx -- )
31 : input-available ( fd mx -- )
32 reads>> delete-at* drop [ resume ] each ;
34 : output-available ( fd mx -- )
35 writes>> delete-at* drop [ resume ] each ;