refactor(types): remove internal APIs from Subscription and Observable

ReactiveX · Feb 22, 2018 · f359f51 · f359f51
1 parent 97c2284
commit f359f51
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/src/internal/Observable.ts b/src/internal/Observable.ts
@@ -17,9 +17,12 @@ import { pipeFromArray } from './util/pipe';
  */
 export class Observable<T> implements Subscribable<T> {
 
+ /** @internal */
  public _isScalar: boolean = false;
 
+ /** @internal */
  protected source: Observable<any>;
+ /** @internal */
  protected operator: Operator<any, T>;
 
  /**
@@ -240,6 +243,7 @@ export class Observable<T> implements Subscribable<T> {
  });
  }
 
+ /** @internal */
  protected _subscribe(subscriber: Subscriber<any>): TeardownLogic {
  return this.source.subscribe(subscriber);
  }

diff --git a/src/internal/Subscription.ts b/src/internal/Subscription.ts
@@ -30,7 +30,9 @@ export class Subscription implements SubscriptionLike {
  */
  public closed: boolean = false;
 
+ /** @internal */
  protected _parent: Subscription = null;
+ /** @internal */
  protected _parents: Subscription[] = null;
  /** @internal */
  private _subscriptions: SubscriptionLike[] = null;
@@ -192,6 +194,7 @@ export class Subscription implements SubscriptionLike {
  }
  }
 
+ /** @internal */
  private _addParent(parent: Subscription) {
  let { _parent, _parents } = this;
  if (!_parent || _parent === parent) {

diff --git a/src/internal/observable/ConnectableObservable.ts b/src/internal/observable/ConnectableObservable.ts
@@ -14,6 +14,7 @@ export class ConnectableObservable<T> extends Observable<T> {
  protected _subject: Subject<T>;
  protected _refCount: number = 0;
  protected _connection: Subscription;
+ /** @internal */
  _isComplete = false;
 
  constructor(protected source: Observable<T>,