Builds a ConnectableObservable for the given observable source and a given Subject.
Creates a ConnectableObservable that takes elements from source
and caches them until the call to connect() happens.
Creates a ConnectableObservable that takes elements from source
and caches them until the call to connect() happens. After that
the events are piped through the given subject to the final
subscribers.