On socket errors, invoke OnError on Receiver and Sender observables

[mauroa]

Currently there is no way for a subscriber to either observables to know that a socket error happened (i.e. for logging, attempt reconnect, etc.)