Skip to content

Commit 2768e44

Browse files
committed
fix: remove onError and onClose from example
1 parent 2789fc8 commit 2768e44

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

example/stream.php

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -58,15 +58,9 @@
5858

5959
// Without QueryBuilder
6060
$dbFactory->streamQuery("select id from Users where id > 1")
61-
->onError(function (Exception $result) {
62-
echo "Error " . $result->getMessage() . PHP_EOL;
63-
})
6461
->onData(function ($result) {
6562
echo "New Row Data:" . json_encode($result) . PHP_EOL;
6663
})
67-
->onClosed(function () {
68-
echo "Task Finished";
69-
})
7064
->run();
7165

7266
$loop->addPeriodicTimer(1, function () {

0 commit comments

Comments
 (0)