Fix error handling from send/receive observables so that they follow the OnError codepath