1
1
import Observable from './Observable' ;
2
2
import Scheduler from './Scheduler' ;
3
3
import ConnectableObservable from './observables/ConnectableObservable' ;
4
- import Subject from './Subject'
4
+ import Subject from './Subject' ;
5
5
import { GroupedObservable } from './operators/groupBy-support' ;
6
6
import Notification from './Notification' ;
7
7
8
8
export interface CoreOperators < T > {
9
9
buffer ?: ( closingNotifier : Observable < any > ) => Observable < T [ ] > ;
10
10
bufferCount ?: ( bufferSize : number , startBufferEvery : number ) => Observable < T [ ] > ;
11
11
bufferTime ?: ( bufferTimeSpan : number , bufferCreationInterval ?: number , scheduler ?: Scheduler ) => Observable < T [ ] > ;
12
- bufferToggle ?: < O > ( openings : Observable < O > , closingSelector ?: ( openValue : O ) => Observable < any > ) => Observable < T [ ] >
12
+ bufferToggle ?: < O > ( openings : Observable < O > , closingSelector ?: ( openValue : O ) => Observable < any > ) => Observable < T [ ] > ;
13
13
bufferWhen ?: ( closingSelector : ( ) => Observable < any > ) => Observable < T [ ] > ;
14
14
catch ?: ( selector : ( err : any , source : Observable < T > , caught : Observable < any > ) => Observable < any > ) => Observable < T > ;
15
15
combineAll ?: < R > ( project ?: ( ...values : Array < any > ) => R ) => Observable < R > ;
@@ -32,7 +32,7 @@ export interface CoreOperators<T> {
32
32
first ?: < R > ( predicate ?: ( value : T , index : number , source : Observable < T > ) => boolean , resultSelector ?: ( value : T , index : number ) => R , thisArg ?: any , defaultValue ?: any ) => Observable < T > | Observable < R > ;
33
33
flatMap ?: < R > ( project : ( ( x : T , ix : number ) => Observable < any > ) , projectResult ?: ( x : T , y : any , ix : number , iy : number ) => R , concurrent ?: number ) => Observable < R > ;
34
34
flatMapTo ?: < R > ( observable : Observable < any > , projectResult ?: ( x : T , y : any , ix : number , iy : number ) => R , concurrent ?: number ) => Observable < R > ;
35
- groupBy ?: < R > ( keySelector : ( value :T ) => string , elementSelector ?: ( value : T ) => R , durationSelector ?: ( group : GroupedObservable < R > ) => Observable < any > ) => Observable < GroupedObservable < R > > ;
35
+ groupBy ?: < R > ( keySelector : ( value : T ) => string , elementSelector ?: ( value : T ) => R , durationSelector ?: ( group : GroupedObservable < R > ) => Observable < any > ) => Observable < GroupedObservable < R > > ;
36
36
ignoreElements ?: ( ) => Observable < T > ;
37
37
last ?: < R > ( predicate ?: ( value : T , index : number ) => boolean , resultSelector ?: ( value : T , index : number ) => R , thisArg ?: any , defaultValue ?: any ) => Observable < T > | Observable < R > ;
38
38
every ?: ( predicate : ( value : T , index : number ) => boolean , thisArg ?: any ) => Observable < T > ;
0 commit comments