module Rx::Util