Directly refer to example core.async functions