chore: fix test description and comment

ReactiveX · Feb 24, 2021 · 1583702 · 1583702
1 parent e8b05ef
commit 1583702
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/spec/operators/buffer-spec.ts b/spec/operators/buffer-spec.ts
@@ -28,7 +28,7 @@ describe('Observable.prototype.buffer', () => {
     });
   });
 
-  it('should not emit a final buffer if the closingNotifier is already complete', () => {
+  it('should emit a final buffer if the closingNotifier is already complete', () => {
     testScheduler.run(({ hot, expectObservable }) => {
       const a = hot('   -a-b-c-d-e-f-g-h-i-|');
       const b = hot('   -----B-----B--|');

diff --git a/src/internal/operators/buffer.ts b/src/internal/operators/buffer.ts
@@ -44,8 +44,7 @@ import { OperatorSubscriber } from './OperatorSubscriber';
  */
 export function buffer<T>(closingNotifier: Observable<any>): OperatorFunction<T, T[]> {
   return operate((source, subscriber) => {
-    // The current buffered values. If this is null, it's because the
-    // closingNotifier has completed before the source.
+    // The current buffered values.
     let currentBuffer: T[] = [];
 
     // Subscribe to our source.