File tree 7 files changed +13
-52
lines changed
7 files changed +13
-52
lines changed Original file line number Diff line number Diff line change 4
4
5
5
$ source = Rx \Observable::range (0 , 9 )->average ();
6
6
7
- $ subscription = $ source ->subscribeCallback (
8
- function ($ x ) {
9
- echo 'Next: ' . $ x . PHP_EOL ;
10
- },
11
- function ($ err ) {
12
- echo 'Error: ' . $ err . PHP_EOL ;
13
- },
14
- function () {
15
- echo 'Completed ' . PHP_EOL ;
16
- }
17
- );
18
-
19
- // => Next: 4
20
- // => Completed
7
+ $ subscription = $ source ->subscribe ($ stdoutObserver );
Original file line number Diff line number Diff line change 1
- Next: 4
2
- Completed
1
+ Next value : 4
2
+ Complete!
Original file line number Diff line number Diff line change 9
9
])
10
10
->pluck ('value ' );
11
11
12
- $ subscription = $ source ->subscribeCallback (
13
- function ($ x ) {
14
- echo 'Next: ' . $ x . PHP_EOL ;
15
- },
16
- function ($ err ) {
17
- echo 'Error: ' . $ err . PHP_EOL ;
18
- },
19
- function () {
20
- echo 'Completed ' . PHP_EOL ;
21
- }
22
- );
23
-
24
- // => Next: 0
25
- // => Next: 1
26
- // => Next: 2
27
- // => Completed
12
+ $ subscription = $ source ->subscribe ($ stdoutObserver );
Original file line number Diff line number Diff line change 1
- Next: 0
2
- Next: 1
3
- Next: 2
4
- Completed
1
+ Next value: 0
2
+ Next value: 1
3
+ Next value: 2
4
+ Complete!
5
+
Original file line number Diff line number Diff line change 5
5
$ source = Rx \Observable::range (1 , 10 )
6
6
->sum ();
7
7
8
- $ subscription = $ source ->subscribeCallback (
9
- function ($ x ) {
10
- echo 'Next: ' . $ x . PHP_EOL ;
11
- },
12
- function ($ err ) {
13
- echo 'Error: ' . $ err . PHP_EOL ;
14
- },
15
- function () {
16
- echo 'Completed ' . PHP_EOL ;
17
- });
18
-
19
- // => Next: 55
20
- // => Completed
8
+ $ subscription = $ source ->subscribe ($ stdoutObserver );
Original file line number Diff line number Diff line change 1
- Next: 55
2
- Completed
1
+ Next value : 55
2
+ Complete!
Original file line number Diff line number Diff line change @@ -641,7 +641,7 @@ public function takeWhileWithIndex(callable $predicate)
641
641
*
642
642
* @demo take/takeLast.php
643
643
* @operator
644
- * @reactivex takelast
644
+ * @reactivex takeLast
645
645
*/
646
646
public function takeLast ($ count )
647
647
{
You can’t perform that action at this time.
0 commit comments