@@ -7,7 +7,7 @@ export const bufferTime: OperatorDoc = {
7
7
bufferTimeSpan: number,
8
8
bufferCreationInterval: number,
9
9
maxBufferSize: number,
10
- scheduler: Scheduler): Observable<T[]> ` ,
10
+ scheduler: Scheduler): Observable` ,
11
11
parameters : [
12
12
{
13
13
name : 'bufferTimeSpan' ,
@@ -66,6 +66,8 @@ export const bufferTime: OperatorDoc = {
66
66
const buffered = clicks.pipe(
67
67
bufferTime(2500)
68
68
);
69
+ buffered.subscribe(x => console.log(x));
70
+
69
71
/*
70
72
Example console output
71
73
@@ -100,13 +102,10 @@ export const bufferTime: OperatorDoc = {
100
102
101
103
[]
102
104
*/
103
-
104
-
105
- buffered.subscribe(x => console.log(x));
106
105
` ,
107
106
externalLink : {
108
107
platform : 'JSBin' ,
109
- url : 'http://jsbin.com/fuqewiy/6 /embed?js,console,output'
108
+ url : 'http://jsbin.com/fuqewiy/7 /embed?js,console,output'
110
109
}
111
110
} ,
112
111
{
@@ -120,6 +119,7 @@ export const bufferTime: OperatorDoc = {
120
119
const buffered = clicks.pipe(
121
120
bufferTime(2000, 5000)
122
121
);
122
+ buffered.subscribe(x => console.log(x));
123
123
124
124
/*
125
125
Example console output:
@@ -158,11 +158,10 @@ export const bufferTime: OperatorDoc = {
158
158
159
159
[]
160
160
*/
161
- buffered.subscribe(x => console.log(x));
162
161
` ,
163
162
externalLink : {
164
163
platform : 'JSBin' ,
165
- url : 'http://jsbin.com/xohupot/4 /embed?js,console,output'
164
+ url : 'http://jsbin.com/xohupot/6 /embed?js,console,output'
166
165
}
167
166
}
168
167
] ,
0 commit comments