diff --git a/docs_app/src/assets/images/marble-diagrams/bufferWhen.png b/docs_app/src/assets/images/marble-diagrams/bufferWhen.png deleted file mode 100644 index 6165954d4d..0000000000 Binary files a/docs_app/src/assets/images/marble-diagrams/bufferWhen.png and /dev/null differ diff --git a/docs_app/src/assets/images/marble-diagrams/bufferWhen.svg b/docs_app/src/assets/images/marble-diagrams/bufferWhen.svg new file mode 100644 index 0000000000..faa0c3da80 --- /dev/null +++ b/docs_app/src/assets/images/marble-diagrams/bufferWhen.svg @@ -0,0 +1 @@ +hgfedcbasbufferWhen()[g, h][d, e, f][a, b, c] \ No newline at end of file diff --git a/docs_app/src/assets/images/marble-diagrams/delay.png b/docs_app/src/assets/images/marble-diagrams/delay.png deleted file mode 100644 index 4f296f32c0..0000000000 Binary files a/docs_app/src/assets/images/marble-diagrams/delay.png and /dev/null differ diff --git a/docs_app/tools/marbles/diagrams/bufferWhen.txt b/docs_app/tools/marbles/diagrams/bufferWhen.txt new file mode 100644 index 0000000000..65a73e61dc --- /dev/null +++ b/docs_app/tools/marbles/diagrams/bufferWhen.txt @@ -0,0 +1,15 @@ +[styles] +event_radius = 33 +operator_height = 60 +completion_height = 80 + +---a---b---c---d---e---f---g---h---| + +-------------s + +> bufferWhen() + +-------------x------------y--------(z|) +x := [a, b, c] +y := [d, e, f] +z := [g, h] diff --git a/spec/operators/bufferWhen-spec.ts b/spec/operators/bufferWhen-spec.ts index 34f5390c3f..b0a4a86ae5 100644 --- a/spec/operators/bufferWhen-spec.ts +++ b/spec/operators/bufferWhen-spec.ts @@ -1,6 +1,6 @@ import { expect } from 'chai'; -import { of, EMPTY, Observable } from 'rxjs'; -import { bufferWhen, mergeMap, takeWhile, take } from 'rxjs/operators'; +import { of } from 'rxjs'; +import { bufferWhen, mergeMap, takeWhile } from 'rxjs/operators'; import { TestScheduler } from 'rxjs/testing'; import { observableMatcher } from '../helpers/observableMatcher'; @@ -16,7 +16,7 @@ describe('bufferWhen operator', () => { testScheduler.run(({ hot, cold, expectObservable }) => { const e1 = hot('--a--^---b---c---d---e---f---g---------| '); const e2 = cold(' --------------(s|) '); - // --------------(s |) + // --------------(s|) const expected = ' --------------x-------------y-----(z|)'; const values = { x: ['b', 'c', 'd'], diff --git a/src/internal/operators/bufferWhen.ts b/src/internal/operators/bufferWhen.ts index 07dd7d280b..00e8c13544 100644 --- a/src/internal/operators/bufferWhen.ts +++ b/src/internal/operators/bufferWhen.ts @@ -13,7 +13,7 @@ import { innerFrom } from '../observable/innerFrom'; * starts collecting values, it calls a function that returns an Observable that * tells when to close the buffer and restart collecting. * - * ![](bufferWhen.png) + * ![](bufferWhen.svg) * * Opens a buffer immediately, then closes the buffer when the observable * returned by calling `closingSelector` function emits a value. When it closes