chore(test): reorder test cases

relates to #1460

spec/operators/bufferToggle-spec.ts

@@ -343,7 +343,7 @@ describe('Observable.prototype.bufferToggle', () => {
  expectSubscriptions(e2.subscriptions).toBe(e2subs);
  });
 
- it('should accept closing selector returns promise resolves', (done: DoneSignature) => {
+ it('should accept closing selector that returns a resolved promise', (done: DoneSignature) => {
  const e1 = Observable.concat(Observable.of(1),
  Observable.timer(10).mapTo(2),
  Observable.timer(10).mapTo(3),
@@ -361,7 +361,7 @@ describe('Observable.prototype.bufferToggle', () => {
  });
  });
 
- it('should accept closing selector returns promise rejects', (done: DoneSignature) => {
+ it('should accept closing selector that returns a rejected promise', (done: DoneSignature) => {
  const e1 = Observable.concat(Observable.of(1),
  Observable.timer(10).mapTo(2),
  Observable.timer(10).mapTo(3),

spec/operators/publishReplay-spec.ts

@@ -23,6 +23,34 @@ describe('Observable.prototype.publishReplay', () => {
  expect(source instanceof Rx.ConnectableObservable).toBe(true);
  });
 
+ it('should follow the RxJS 4 behavior and NOT allow you to reconnect by subscribing again', (done: DoneSignature) => {
+ const expected = [1, 2, 3, 4];
+ let i = 0;
+
+ const source = Observable.of(1, 2, 3, 4).publishReplay(1);
+
+ const results = [];
+
+ source.subscribe(
+ (x: number) => {
+ expect(x).toBe(expected[i++]);
+ },
+ done.fail,
+ () => {
+ i = 0;
+
+ source.subscribe((x: number) => {
+ results.push(x);
+ }, done.fail, done);
+
+ source.connect();
+ });
+
+ source.connect();
+
+ expect(results).toEqual([4]);
+ });
+
  it('should do nothing if connect is not called, despite subscriptions', () => {
  const source = cold('--1-2---3-4--5-|');
  const sourceSubs = [];
@@ -356,32 +384,4 @@ describe('Observable.prototype.publishReplay', () => {
 
  published.connect();
  });
-
- it('should follow the RxJS 4 behavior and NOT allow you to reconnect by subscribing again', (done: DoneSignature) => {
- const expected = [1, 2, 3, 4];
- let i = 0;
-
- const source = Observable.of(1, 2, 3, 4).publishReplay(1);
-
- const results = [];
-
- source.subscribe(
- (x: number) => {
- expect(x).toBe(expected[i++]);
- },
- done.fail,
- () => {
- i = 0;
-
- source.subscribe((x: number) => {
- results.push(x);
- }, done.fail, done);
-
- source.connect();
- });
-
- source.connect();
-
- expect(results).toEqual([4]);
- });
 });

src/operator/bufferToggle.ts

@@ -17,7 +17,7 @@ import {InnerSubscriber} from '../InnerSubscriber';
  * @param {Observable<O>} openings An observable of notifications to start new
  * buffers.
  * @param {Function} closingSelector a function that takes the value emitted by
- * the `openings` observable and returns an Observable, which, when it emits,
+ * the `openings` observable and returns an Subscribable or Promise, which, when it emits,
  * signals that the associated buffer should be emitted and cleared.
  * @return {Observable<T[]>} an observable of arrays of buffered values.
  * @method bufferToggle