Skip to content

Commit e7db33f

Browse files
asm89asm89
committed
Add .expect files for most demos
For most demos it is easy to add an expect file. Some demos have been changed slightly to not run forever or run a bit faster. There are a few demos that are time based. They might turn out to be flaky "tests", but let's give it a shot for now as we're talking about hundreds of milliseconds timing not microseconds.
1 parent 883ad4b commit e7db33f

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

48 files changed

+241
-11
lines changed

‎demo/count/count.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 10
2+
Complete!

‎demo/create/create.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
$observer->onCompleted();
1111

1212
return new CallbackDisposable(function () {
13-
echo "Disposed \n";
13+
echo "Disposed\n";
1414
});
1515
});
1616

@@ -27,7 +27,7 @@
2727
$observer->onCompleted();
2828

2929
return new CallbackDisposable(function () {
30-
echo "Disposed \n";
30+
echo "Disposed\n";
3131
});
3232
});
3333

‎demo/create/create.php.expect

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
Next value: 42
2+
Complete!
3+
Disposed
4+
Next value: 42
5+
Complete!
6+
Disposed

‎demo/defaultIfEmpty/defaultIfEmpty.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: something
2+
Complete!

‎demo/defer/defer.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 42
2+
Complete!

‎demo/delay/delay.php.expect

+11
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
Side effect: 0
2+
Next value: 0
3+
Side effect: 1
4+
Next value: 1
5+
Side effect: 2
6+
Next value: 2
7+
Side effect: 3
8+
Next value: 3
9+
Side effect: 4
10+
Next value: 4
11+
Complete!

‎demo/distinct/distinct.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 42
2+
Next value: 24
3+
Complete!

‎demo/distinct/distinctKey.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 42
2+
Next value: 24
3+
Complete!

‎demo/distinct/distinctUntilChanged.php.expect

+4
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
Next value: 24
2+
Next value: 42
3+
Next value: 24
4+
Complete!

‎demo/distinct/distinctUntilKeyChanged.php.expect

+4
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
Next value: 24
2+
Next value: 42
3+
Next value: 24
4+
Complete!

‎demo/empty-observable/empty-observable.php.expect

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Complete!

‎demo/error-observable/error-observable.php.expect

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Exception: Oops!

‎demo/filter/filter.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 42
2+
Next value: 84
3+
Complete!

‎demo/flatMap/flatMap.php.expect

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
Next value: 1
2+
Next value: 1
3+
Next value: 2
4+
Next value: 1
5+
Next value: 2
6+
Next value: 1
7+
Next value: 2
8+
Next value: 3
9+
Next value: 1
10+
Next value: 2
11+
Next value: 3
12+
Next value: 3
13+
Next value: 4
14+
Next value: 4
15+
Next value: 5
16+
Complete!

‎demo/fromArray/fromArray.php.expect

+5
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
Next value: 1
2+
Next value: 2
3+
Next value: 3
4+
Next value: 4
5+
Complete!

‎demo/groupBy/groupBy.php.expect

+8
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
1: Next value: 21
2+
0: Next value: 42
3+
1: Next value: 21
4+
0: Next value: 42
5+
1: Next value: 21
6+
0: Next value: 42
7+
1: Complete!
8+
0: Complete!

‎demo/interval/interval.php.expect

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
Next value: 0
2+
Next value: 1
3+
Next value: 2
4+
Next value: 3
5+
Next value: 4
6+
Complete!

‎demo/iterator/iterator.php.expect

+4
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
Next value: 1
2+
Next value: 2
3+
Next value: 3
4+
Complete!

‎demo/just/just.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 42
2+
Complete!

‎demo/map/map.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 42
2+
Next value: 84
3+
Complete!

‎demo/map/mapTo.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 1
2+
Next value: 1
3+
Complete!

‎demo/map/mapWithIndex.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 21
2+
Next value: 43
3+
Complete!

‎demo/merge/merge.php

+3-7
Original file line numberDiff line numberDiff line change
@@ -7,16 +7,12 @@
77

88
$observable = Rx\Observable::just(42)->repeat();
99
$otherObservable = Rx\Observable::just(21)->repeat();
10-
$mergedObservable = $observable->merge($otherObservable, $scheduler);
10+
$mergedObservable = $observable
11+
->merge($otherObservable, $scheduler)
12+
->take(10);
1113

1214
$disposable = $mergedObservable->subscribe($stdoutObserver, $scheduler);
1315

14-
$loop->addPeriodicTimer(0.01, function () {
15-
$memory = memory_get_usage() / 1024;
16-
$formatted = number_format($memory, 3) . 'K';
17-
echo "Current memory usage: {$formatted}\n";
18-
});
19-
2016
$loop->run();
2117

2218

‎demo/merge/merge.php.expect

+11
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
Next value: 42
2+
Next value: 21
3+
Next value: 42
4+
Next value: 21
5+
Next value: 42
6+
Next value: 21
7+
Next value: 42
8+
Next value: 21
9+
Next value: 42
10+
Next value: 21
11+
Complete!

‎demo/multicast/multicast.php.expect

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
Next value: 0
2+
Next value: 0
3+
Next value: 1
4+
Next value: 1
5+
Next value: 2
6+
Next value: 2
7+
Complete!

‎demo/publish/publish.php.expect

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
Side effect
2+
SourceA Next value: 0
3+
Side effect
4+
SourceA Next value: 1
5+
SourceA Complete!
6+
SourceB Next value: 0
7+
SourceB Next value: 1
8+
SourceB Complete!
9+
Side effect
10+
SourceC Next value: 0
11+
SourceD Next value: 0
12+
Side effect
13+
SourceC Next value: 1
14+
SourceD Next value: 1
15+
SourceC Complete!
16+
SourceD Complete!

‎demo/publish/publishLast.php.expect

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
Side effect
2+
Side effect
3+
SourceANext value: 1
4+
SourceBNext value: 1
5+
SourceAComplete!
6+
SourceBComplete!

‎demo/publish/publishValue.php.expect

+10
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
SourceANext value: 42
2+
SourceBNext value: 42
3+
Side effect
4+
SourceANext value: 0
5+
SourceBNext value: 0
6+
Side effect
7+
SourceANext value: 1
8+
SourceBNext value: 1
9+
SourceAComplete!
10+
SourceBComplete!

‎demo/range/range.php.expect

+4
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
Next value: 0
2+
Next value: 1
3+
Next value: 2
4+
Complete!

‎demo/react/defer.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 42
2+
Complete!

‎demo/react/promise-from-observable.php.expect

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Value 42

‎demo/react/promise-to-observable.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 42
2+
Complete!
3+
Exception: because

‎demo/reduce/reduce.php.expect

+4
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
Next value: 6
2+
Complete!
3+
Next value: 6
4+
Complete!

‎demo/repeat/repeat.php.expect

+10
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
Next value: 1
2+
Next value: 2
3+
Next value: 3
4+
Next value: 1
5+
Next value: 2
6+
Next value: 3
7+
Next value: 1
8+
Next value: 2
9+
Next value: 3
10+
Complete!

‎demo/retry/retry.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 42
2+
Complete!

‎demo/return-observable/return-observable.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 42
2+
Complete!

‎demo/scan/scan.php.expect

+8
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
Next value: 1
2+
Next value: 3
3+
Next value: 6
4+
Complete!
5+
Next value: 1
6+
Next value: 2
7+
Next value: 6
8+
Complete!

‎demo/share/share.php.expect

+17
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
Side effect
2+
SourceANext value: 0
3+
Side effect
4+
SourceBNext value: 0
5+
Side effect
6+
SourceANext value: 1
7+
SourceAComplete!
8+
SourceBNext value: 1
9+
SourceBComplete!
10+
Side effect
11+
SourceANext value: 0
12+
SourceBNext value: 0
13+
Side effect
14+
SourceANext value: 1
15+
SourceBNext value: 1
16+
SourceAComplete!
17+
SourceBComplete!

‎demo/skip/skip.php.expect

+5
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
Next value: 3
2+
Next value: 5
3+
Next value: 8
4+
Next value: 13
5+
Complete!

‎demo/start/start.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 42
2+
Complete!

‎demo/subscribeOn/subscribeOn.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 42
2+
Complete!

‎demo/take/take.php.expect

+3
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Next value: 21
2+
Next value: 42
3+
Complete!

‎demo/take/takeUntil.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,15 @@
44

55
$loop = \React\EventLoop\Factory::create();
66
$timeout = \Rx\Observable::create(function (\Rx\ObserverInterface $o) use ($loop) {
7-
$loop->addTimer(6, function () use ($o) {
7+
$loop->addTimer(1, function () use ($o) {
88
$o->onNext(0);
99
});
1010

1111
return new \Rx\Disposable\EmptyDisposable();
1212
});
1313

1414
$scheduler = new \Rx\Scheduler\EventLoopScheduler($loop);
15-
$source = \Rx\Observable::interval(1000, $scheduler)->takeUntil($timeout);
15+
$source = \Rx\Observable::interval(100, $scheduler)->takeUntil($timeout);
1616

1717
$subscription = $source->subscribe($stdoutObserver);
1818

‎demo/take/takeUntil.php.expect

+10
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
Next value: 0
2+
Next value: 1
3+
Next value: 2
4+
Next value: 3
5+
Next value: 4
6+
Next value: 5
7+
Next value: 6
8+
Next value: 7
9+
Next value: 8
10+
Complete!

‎demo/timeout/timeout.php.expect

+5
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
100 ms - Next value: 0
2+
100 ms - Next value: 1
3+
100 ms - Next value: 2
4+
100 ms - Complete!
5+
One second - Exception: timeout

‎demo/timer/timer.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: 0
2+
Complete!

‎demo/toArray/toArray.php.expect

+2
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
Next value: [1,2,3,4]
2+
Complete!

‎demo/zip/zip.php.expect

+8
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
Next value: [0,1,2]
2+
Next value: [1,2,3]
3+
Next value: [2,3,4]
4+
Complete!
5+
Next value: 0:1:2
6+
Next value: 1:2:3
7+
Next value: 2:3:4
8+
Complete!

0 commit comments

Comments
 (0)