Fix count action
add nest(), retry()
rename consume(key, observable) to notify
set keepAlive true to default Stream
Fix race condition in parallel action