Closed Alban-io closed 5 years ago
Whatever you can call produceNextCallback anywhere :
produceNextCallback
$reader = new \Rxnet\OnDemand\OnDemandFileReader("./test.csv"); $reader ->getObservable() ->doOnNext(function ($row) { echo "got row : {$row}" . PHP_EOL; }) ->subscribeCallback($reader->produceNextCallback()); $reader->produceNext(1);
Whatever you can call
produceNextCallback
anywhere :