feat(refactor): move ./interfaces.ts to internal/types.ts

BREAKING CHANGE: Can no longer explicitly import types from `rxjs/interfaces`, import them from `rxjs` instead

src/index.ts

@@ -147,3 +147,6 @@ export { Notification } from './internal/Notification';
 
 /* Utils */
 export { pipe } from './util/pipe';
+
+/* Types */
+export * from './internal/types';

src/internal/Observable.ts

@@ -7,7 +7,7 @@ import { toSubscriber } from '../util/toSubscriber';
 import { IfObservable } from './observable/IfObservable';
 import { ErrorObservable } from './observable/ErrorObservable';
 import { observable as Symbol_observable } from '../internal/symbol/observable';
-import { OperatorFunction } from '../interfaces';
+import { OperatorFunction } from '../internal/types';
 import { pipeFromArray } from '../util/pipe';
 
 export interface Subscribable<T> {

src/internal/operators/audit.ts

@@ -7,7 +7,7 @@ import { tryCatch } from '../../util/tryCatch';
 import { errorObject } from '../../util/errorObject';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Ignores source values for a duration determined by another Observable, then

src/internal/operators/auditTime.ts

@@ -2,7 +2,7 @@ import { async } from '../scheduler/async';
 import { IScheduler } from '../Scheduler';
 import { audit } from './audit';
 import { timer } from '../observable/timer';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Ignores source values for `duration` milliseconds, then emits the most recent

src/internal/operators/buffer.ts

@@ -4,7 +4,7 @@ import { Observable } from '../Observable';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Buffers the source Observable values until `closingNotifier` emits.

src/internal/operators/bufferCount.ts

@@ -2,7 +2,7 @@ import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { Observable } from '../Observable';
 import { TeardownLogic } from '../Subscription';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Buffers the source Observable values until the size hits the maximum

src/internal/operators/bufferTime.ts

@@ -6,7 +6,7 @@ import { Observable } from '../Observable';
 import { Subscriber } from '../Subscriber';
 import { Subscription } from '../Subscription';
 import { isScheduler } from '../../util/isScheduler';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function bufferTime<T>(bufferTimeSpan: number, scheduler?: IScheduler): OperatorFunction<T, T[]>;

src/internal/operators/bufferToggle.ts

@@ -5,7 +5,7 @@ import { Subscription } from '../Subscription';
 import { subscribeToResult } from '../../util/subscribeToResult';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Buffers the source Observable values starting from an emission from

src/internal/operators/bufferWhen.ts

@@ -7,7 +7,7 @@ import { errorObject } from '../../util/errorObject';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Buffers the source Observable values, using a factory function of closing

src/internal/operators/catchError.ts

@@ -4,7 +4,7 @@ import { Observable, ObservableInput } from '../Observable';
 
 import { OuterSubscriber } from '../OuterSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Catches errors on the observable to be handled by returning a new observable or throwing an error.

src/internal/operators/combineAll.ts

@@ -1,6 +1,6 @@
 import { CombineLatestOperator } from '../observable/combineLatest';
 import { Observable } from '../Observable';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 export function combineAll<T, R>(project?: (...values: Array<any>) => R): OperatorFunction<T, R> {
   return (source: Observable<T>) => source.lift(new CombineLatestOperator(project));

src/internal/operators/concatAll.ts

@@ -1,6 +1,6 @@
 
 import { mergeAll } from './mergeAll';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Converts a higher-order Observable into a first-order Observable by

src/internal/operators/concatMap.ts

@@ -1,6 +1,6 @@
 import { mergeMap } from './mergeMap';
 import { ObservableInput } from '../Observable';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function concatMap<T, R>(project: (value: T, index: number) =>  ObservableInput<R>): OperatorFunction<T, R>;

src/internal/operators/concatMapTo.ts

@@ -1,6 +1,6 @@
 import { Observable, ObservableInput } from '../Observable';
 import { concatMap } from './concatMap';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function concatMapTo<T, R>(observable: ObservableInput<R>): OperatorFunction<T, R>;

src/internal/operators/count.ts

@@ -2,7 +2,7 @@ import { Observable } from '../Observable';
 import { Operator } from '../Operator';
 import { Observer } from '../Observer';
 import { Subscriber } from '../Subscriber';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Counts the number of emissions on the source and emits that number when the

src/internal/operators/debounce.ts

@@ -6,7 +6,7 @@ import { Subscription, TeardownLogic } from '../Subscription';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Emits a value from the source Observable only after a particular time span

src/internal/operators/debounceTime.ts

@@ -4,7 +4,7 @@ import { Subscriber } from '../Subscriber';
 import { IScheduler } from '../Scheduler';
 import { Subscription, TeardownLogic } from '../Subscription';
 import { async } from '../scheduler/async';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Emits a value from the source Observable only after a particular time span

src/internal/operators/defaultIfEmpty.ts

@@ -1,7 +1,7 @@
 import { Operator } from '../Operator';
 import { Observable } from '../Observable';
 import { Subscriber } from '../Subscriber';
-import { OperatorFunction, MonoTypeOperatorFunction } from '../../interfaces';
+import { OperatorFunction, MonoTypeOperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function defaultIfEmpty<T>(defaultValue?: T): MonoTypeOperatorFunction<T>;

src/internal/operators/delay.ts

@@ -8,7 +8,7 @@ import { Notification } from '../Notification';
 import { Observable } from '../Observable';
 import { PartialObserver } from '../Observer';
 import { TeardownLogic } from '../Subscription';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Delays the emission of items from the source Observable by a given timeout or

src/internal/operators/delayWhen.ts

@@ -5,7 +5,7 @@ import { Subscription, TeardownLogic } from '../Subscription';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Delays the emission of items from the source Observable by a given time span

src/internal/operators/dematerialize.ts

@@ -2,7 +2,7 @@ import { Operator } from '../Operator';
 import { Observable } from '../Observable';
 import { Subscriber } from '../Subscriber';
 import { Notification } from '../Notification';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Converts an Observable of {@link Notification} objects into the emissions

src/internal/operators/distinct.ts

@@ -5,7 +5,7 @@ import { TeardownLogic } from '../Subscription';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 if (!Set) {
   throw new Error('Set is not present, please polyfill');

src/internal/operators/distinctUntilChanged.ts

@@ -4,7 +4,7 @@ import { tryCatch } from '../../util/tryCatch';
 import { errorObject } from '../../util/errorObject';
 import { Observable } from '../Observable';
 import { TeardownLogic } from '../Subscription';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function distinctUntilChanged<T>(compare?: (x: T, y: T) => boolean): MonoTypeOperatorFunction<T>;

src/internal/operators/distinctUntilKeyChanged.ts

@@ -1,5 +1,5 @@
 import { distinctUntilChanged } from './distinctUntilChanged';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function distinctUntilKeyChanged<T>(key: string): MonoTypeOperatorFunction<T>;

src/internal/operators/elementAt.ts

@@ -3,7 +3,7 @@ import { Subscriber } from '../Subscriber';
 import { ArgumentOutOfRangeError } from '../../util/ArgumentOutOfRangeError';
 import { Observable } from '../Observable';
 import { TeardownLogic } from '../Subscription';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Emits the single value at the specified `index` in a sequence of emissions

src/internal/operators/every.ts

@@ -2,7 +2,7 @@ import { Operator } from '../Operator';
 import { Observer } from '../Observer';
 import { Observable } from '../Observable';
 import { Subscriber } from '../Subscriber';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Returns an Observable that emits whether or not every item of the source satisfies the condition specified.

src/internal/operators/exhaust.ts

@@ -4,7 +4,7 @@ import { Subscriber } from '../Subscriber';
 import { Subscription, TeardownLogic } from '../Subscription';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Converts a higher-order Observable into a first-order Observable by dropping

src/internal/operators/exhaustMap.ts

@@ -5,7 +5,7 @@ import { Subscription } from '../Subscription';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function exhaustMap<T, R>(project: (value: T, index: number) => ObservableInput<R>): OperatorFunction<T, R>;

src/internal/operators/expand.ts

@@ -8,7 +8,7 @@ import { Subscription } from '../Subscription';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { MonoTypeOperatorFunction, OperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction, OperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function expand<T>(project: (value: T, index: number) => Observable<T>, concurrent?: number, scheduler?: IScheduler): MonoTypeOperatorFunction<T>;

src/internal/operators/filter.ts

@@ -2,7 +2,7 @@ import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { Observable } from '../Observable';
 import { TeardownLogic } from '../Subscription';
-import { OperatorFunction, MonoTypeOperatorFunction } from '../../interfaces';
+import { OperatorFunction, MonoTypeOperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function filter<T, S extends T>(predicate: (value: T, index: number) => value is S,

src/internal/operators/finalize.ts

@@ -2,7 +2,7 @@ import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { Subscription, TeardownLogic } from '../Subscription';
 import { Observable } from '../Observable';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Returns an Observable that mirrors the source Observable, but will call a specified function when

src/internal/operators/find.ts

@@ -1,7 +1,7 @@
 import { Observable } from '../Observable';
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
-import { OperatorFunction, MonoTypeOperatorFunction } from '../../interfaces';
+import { OperatorFunction, MonoTypeOperatorFunction } from '../../internal/types';
 
 export function find<T, S extends T>(predicate: (value: T, index: number, source: Observable<T>) => value is S,
                                      thisArg?: any): OperatorFunction<T, S>;

src/internal/operators/findIndex.ts

@@ -1,6 +1,6 @@
 import { Observable } from '../Observable';
 import { FindValueOperator } from '../operators/find';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 /**
  * Emits only the index of the first value emitted by the source Observable that
  * meets some condition.

src/internal/operators/first.ts

@@ -2,7 +2,7 @@ import { Observable } from '../Observable';
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { EmptyError } from '../../util/EmptyError';
-import { OperatorFunction, MonoTypeOperatorFunction } from '../../interfaces';
+import { OperatorFunction, MonoTypeOperatorFunction } from '../../internal/types';
 /* tslint:disable:max-line-length */
 export function first<T, S extends T>(predicate: (value: T, index: number, source: Observable<T>) => value is S): OperatorFunction<T, S>;
 export function first<T, S extends T, R>(predicate: (value: T | S, index: number, source: Observable<T>) => value is S,

src/internal/operators/groupBy.ts

@@ -3,7 +3,7 @@ import { Subscription } from '../Subscription';
 import { Observable } from '../Observable';
 import { Operator } from '../Operator';
 import { Subject } from '../Subject';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /** Assert that map is present for this operator */
 if (!Map) {

src/internal/operators/ignoreElements.ts

@@ -1,7 +1,7 @@
 import { Observable } from '../Observable';
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Ignores all items emitted by the source Observable and only passes calls of `complete` or `error`.

src/internal/operators/isEmpty.ts

@@ -1,7 +1,7 @@
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { Observable } from '../Observable';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 export function isEmpty<T>(): OperatorFunction<T, boolean> {
   return (source: Observable<T>) => source.lift(new IsEmptyOperator());

src/internal/operators/last.ts

@@ -2,7 +2,7 @@ import { Observable } from '../Observable';
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { EmptyError } from '../../util/EmptyError';
-import { OperatorFunction, MonoTypeOperatorFunction } from '../../interfaces';
+import { OperatorFunction, MonoTypeOperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function last<T, S extends T>(predicate: (value: T, index: number, source: Observable<T>) => value is S): OperatorFunction<T, S>;

src/internal/operators/map.ts

@@ -1,7 +1,7 @@
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { Observable } from '../Observable';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Applies a given `project` function to each value emitted by the source

src/internal/operators/mapTo.ts

@@ -1,7 +1,7 @@
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { Observable } from '../Observable';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Emits the given constant value on the output Observable every time the source

src/internal/operators/materialize.ts

@@ -2,7 +2,7 @@ import { Operator } from '../Operator';
 import { Observable } from '../Observable';
 import { Subscriber } from '../Subscriber';
 import { Notification } from '../Notification';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /**
  * Represents all of the notifications from the source Observable as `next`

src/internal/operators/max.ts

@@ -1,5 +1,5 @@
 import { reduce } from './reduce';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * The Max operator operates on an Observable that emits numbers (or items that can be compared with a provided function),

src/internal/operators/mergeAll.ts

@@ -2,7 +2,7 @@
 import { ObservableInput } from '../Observable';
 import { mergeMap } from './mergeMap';
 import { identity } from '../../util/identity';
-import { MonoTypeOperatorFunction } from '../../interfaces';
+import { MonoTypeOperatorFunction } from '../../internal/types';
 
 /**
  * Converts a higher-order Observable into a first-order Observable which

src/internal/operators/mergeMap.ts

@@ -5,7 +5,7 @@ import { Subscription } from '../Subscription';
 import { subscribeToResult } from '../../util/subscribeToResult';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function mergeMap<T, R>(project: (value: T, index: number) => ObservableInput<R>, concurrent?: number): OperatorFunction<T, R>;

src/internal/operators/mergeMapTo.ts

@@ -6,7 +6,7 @@ import { Subscription } from '../Subscription';
 import { OuterSubscriber } from '../OuterSubscriber';
 import { InnerSubscriber } from '../InnerSubscriber';
 import { subscribeToResult } from '../../util/subscribeToResult';
-import { OperatorFunction } from '../../interfaces';
+import { OperatorFunction } from '../../internal/types';
 
 /* tslint:disable:max-line-length */
 export function mergeMapTo<T, R>(observable: ObservableInput<R>, concurrent?: number): OperatorFunction<T, R>;