Returns an observable that will call the given block with each source emission, before passing the original emission downstream.