Skip to content

Commit 46077f4

Browse files
committed
Updated broadcast async to RxPHP 2.0
1 parent 852a2c7 commit 46077f4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

examples/broadcasts-async.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,10 @@
1111
$loop = Factory::create();
1212
$client = AsyncClient::create($loop, require 'resolve_key.php');
1313

14-
$client->broadcasts()->subscribe(new CallbackObserver(function (BroadcastInterface $broadcast) {
14+
$client->broadcasts()->subscribe(function (BroadcastInterface $broadcast) {
1515
resource_pretty_print($broadcast);
1616
}, function ($e) {
1717
echo (string)$e;
18-
}));
18+
});
1919

2020
$loop->run();

0 commit comments

Comments
 (0)