style(typings): Updated typings for multicast and publish to return a ConnectableObservable

Author: david-driscoll

src/operators/multicast.ts

@@ -1,8 +1,7 @@
-import {Observable} from '../Observable';
 import {Subject} from '../Subject';
 import {ConnectableObservable} from '../observables/ConnectableObservable';
 
-export function multicast<T>(subjectOrSubjectFactory: Subject<T> | (() => Subject<T>)): Observable<T> {
+export function multicast<T>(subjectOrSubjectFactory: Subject<T> | (() => Subject<T>)): ConnectableObservable<T> {
   let subjectFactory: () => Subject<T>;
   if (typeof subjectOrSubjectFactory === 'function') {
     subjectFactory = <() => Subject<T>>subjectOrSubjectFactory;

src/operators/publish.ts

@@ -1,7 +1,7 @@
-import {Observable} from '../Observable';
+import {ConnectableObservable} from '../observables/ConnectableObservable';
 import {Subject} from '../Subject';
 import {multicast} from './multicast';
 
-export function publish<T>(): Observable<T> {
+export function publish<T>(): ConnectableObservable<T> {
   return multicast.call(this, new Subject());
 }

src/operators/publishBehavior.ts

@@ -1,7 +1,7 @@
-import {Observable} from '../Observable';
+import {ConnectableObservable} from '../observables/ConnectableObservable';
 import {BehaviorSubject} from '../subjects/BehaviorSubject';
 import {multicast} from './multicast';
 
-export function publishBehavior<T>(value: T): Observable<T> {
+export function publishBehavior<T>(value: T): ConnectableObservable<T> {
   return multicast.call(this, new BehaviorSubject(value));
 }

src/operators/publishReplay.ts

@@ -1,11 +1,11 @@
-import {Observable} from '../Observable';
+import {ConnectableObservable} from '../observables/ConnectableObservable';
 import {ReplaySubject} from '../subjects/ReplaySubject';
 import {Scheduler} from '../Scheduler';
 import {multicast} from './multicast';
 
-export function publishReplay<T>(bufferSize?: number, windowTime?: number, scheduler?: Scheduler): Observable<T>;
+export function publishReplay<T>(bufferSize?: number, windowTime?: number, scheduler?: Scheduler): ConnectableObservable<T>;
 export function publishReplay<T>(bufferSize: number = Number.POSITIVE_INFINITY,
                                  windowTime: number = Number.POSITIVE_INFINITY,
-                                 scheduler?: Scheduler): Observable<T> {
+                                 scheduler?: Scheduler): ConnectableObservable<T> {
   return multicast.call(this, new ReplaySubject(bufferSize, windowTime, scheduler));
 }