Added async module, for creating streams from asynchronous values and queues, and did some cleanup / reshuffling - 'variable' now renamed to 'ref'
Switched to System.nanoTime, and implemented every and awakeEvery