socketA, pipeB; watchedList.add(socketA, FOR_READ); watchedList.add(pipeB, FOR_READ); while(events = demultiplexer.watch(watchedList){ // ここでwatchedListのいずれかのリソースが読み込み可能になるまでブロックする foreach(event in events){ /*non blocking read always returns data*/ data = event.resource.read(); if(data===RESOURCE_CLOSED){ /*stop watching if resource closed*/ demultiplexer.unwatch(event.resource); } else consumeData(data); } })