fix commit and use core.async pub/sub