filereader improvement
This commit is contained in:
parent
8e899b64ba
commit
41c19153a3
@ -41,17 +41,11 @@ class AsynchronousFileReader {
|
|||||||
*/
|
*/
|
||||||
public function appendData() {
|
public function appendData() {
|
||||||
foreach ($this->requests as $key => $request) {
|
foreach ($this->requests as $key => $request) {
|
||||||
try {
|
|
||||||
if ($request->socketPerform()) {
|
if ($request->socketPerform()) {
|
||||||
$request->socketSelect();
|
$request->socketSelect();
|
||||||
}
|
}else{
|
||||||
} catch (Exception $e) {
|
|
||||||
if ($e->getMessage() === 'Cannot perform if there are no requests in queue.') {
|
|
||||||
unset($this->requests[$key]);
|
unset($this->requests[$key]);
|
||||||
} else {
|
|
||||||
throw $e;
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user