streampool.pl -- Input multiplexing

This libary allows a single thread to monitor multiple streams and call a goal if input is available on a stream.

bug

- Note that if the processing predicate blocks other input channals are not processed. This may happen, for example, if a read/2 call blocks due to incomplete input.

 delete_stream_from_pool(+Stream)

Retract stream from the pool

 close_stream_pool

Close all streams in the pool. This causes stream_pool_main_loop/0 to terminate.

 dispatch_stream_pool(+TimeOut)

Wait for input on one or more streams and handle that. Wait for at most TimeOut seconds (0 means infinite).

Undocumented predicates

The following predicates are exported, but not or incorrectly documented.

 stream_pool_main_loop

 add_stream_to_pool(Arg1, Arg2)