@@ -2,7 +2,7 @@ import { expect } from 'chai';
2
2
import * as sinon from 'sinon' ;
3
3
import { TeardownLogic } from '../src/internal/types' ;
4
4
import { Observable , config , Subscription , Subscriber , Operator , NEVER , Subject , of , throwError , EMPTY } from 'rxjs' ;
5
- import { map , multicast , refCount , filter , count , tap , combineLatest , concat , merge , race , zip , catchError , publish , publishLast , publishBehavior , share } from 'rxjs/operators' ;
5
+ import { map , multicast , refCount , filter , count , tap , combineLatestWith , concat , merge , race , zip , catchError , publish , publishLast , publishBehavior , share } from 'rxjs/operators' ;
6
6
import { TestScheduler } from 'rxjs/testing' ;
7
7
import { observableMatcher } from './helpers/observableMatcher' ;
8
8
@@ -132,7 +132,7 @@ describe('Observable', () => {
132
132
} ,
133
133
( err ) => {
134
134
results . push ( err ) ;
135
- // The error should unsubscribe from the source, meaning we
135
+ // The error should unsubscribe from the source, meaning we
136
136
// should not see the number 4.
137
137
expect ( results ) . to . deep . equal ( [ 1 , 2 , 3 , expected ] ) ;
138
138
}
@@ -179,7 +179,7 @@ describe('Observable', () => {
179
179
results . push ( value ) ;
180
180
}
181
181
next . bind = ( ) => { /* lol */ } ;
182
-
182
+
183
183
const complete = function ( ) {
184
184
results . push ( 'done' ) ;
185
185
}
@@ -1051,13 +1051,16 @@ describe('Observable.lift', () => {
1051
1051
) ;
1052
1052
} ) ;
1053
1053
1054
- it ( 'should compose through combineLatest ' , ( ) => {
1054
+ it ( 'should compose through combineLatestWith ' , ( ) => {
1055
1055
rxTestScheduler . run ( ( { cold, expectObservable } ) => {
1056
1056
const e1 = cold ( ' -a--b-----c-d-e-|' ) ;
1057
1057
const e2 = cold ( ' --1--2-3-4---| ' ) ;
1058
1058
const expected = '--A-BC-D-EF-G-H-|' ;
1059
1059
1060
- const result = MyCustomObservable . from ( e1 ) . pipe ( combineLatest ( e2 , ( a , b ) => String ( a ) + String ( b ) ) ) ;
1060
+ const result = MyCustomObservable . from ( e1 ) . pipe (
1061
+ combineLatestWith ( e2 ) ,
1062
+ map ( ( [ a , b ] ) => String ( a ) + String ( b ) )
1063
+ ) ;
1061
1064
1062
1065
expect ( result instanceof MyCustomObservable ) . to . be . true ;
1063
1066
0 commit comments