Moved to latest core.async