Yes, I figured out what my mistakes are, and fixing them should allow to us to publish onComplete and onError as we receive them.