robin/streams
1
0
Fork 0
mirror of https://codeberg.org/icewind/streams.git synced 2026-06-03 16:44:07 +02:00
Code Issues Projects Releases Packages Wiki Activity

Check if callable when we actually try to call it

Browse source
This commit is contained in:
Robin Appelman 2014-08-27 15:52:10 +02:00
commit b9bba79250
1 changed files with 8 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

24
src/CallbackWrapper.php
View file

@ -72,18 +72,10 @@ class CallbackWrapper extends Wrapper {
protected function open() { protected function open() {
$context = $this->loadContext('callback'); $context = $this->loadContext('callback');
if (is_callable($context['read'])) { $this->readCallback = $context['read'];
$this->readCallback = $context['read']; $this->writeCallback = $context['write'];
} $this->closeCallback = $context['close'];
if (is_callable($context['write'])) { $this->readDirCallBack = $context['readDir'];
$this->writeCallback = $context['write'];
}
if (is_callable($context['close'])) {
$this->closeCallback = $context['close'];
}
if (is_callable($context['readDir'])) {
$this->readDirCallBack = $context['readDir'];
}
return true; return true;
} }
@ -97,7 +89,7 @@ class CallbackWrapper extends Wrapper {
public function stream_read($count) { public function stream_read($count) {
$result = parent::stream_read($count); $result = parent::stream_read($count);
if ($this->readCallback) { if (is_callable($this->readCallback)) {
call_user_func($this->readCallback, $count); call_user_func($this->readCallback, $count);
} }
return $result; return $result;
@ -105,7 +97,7 @@ class CallbackWrapper extends Wrapper {
public function stream_write($data) { public function stream_write($data) {
$result = parent::stream_write($data); $result = parent::stream_write($data);
if ($this->writeCallback) { if (is_callable($this->writeCallback)) {
call_user_func($this->writeCallback, $data); call_user_func($this->writeCallback, $data);
} }
return $result; return $result;
@ -113,7 +105,7 @@ class CallbackWrapper extends Wrapper {
public function stream_close() { public function stream_close() {
$result = parent::stream_close(); $result = parent::stream_close();
if ($this->closeCallback) { if (is_callable($this->closeCallback)) {
call_user_func($this->closeCallback); call_user_func($this->closeCallback);
} }
return $result; return $result;
@ -121,7 +113,7 @@ class CallbackWrapper extends Wrapper {
public function dir_readdir() { public function dir_readdir() {
$result = parent::dir_readdir(); $result = parent::dir_readdir();
if ($this->readDirCallBack) { if (is_callable($this->readDirCallBack)) {
call_user_func($this->readDirCallBack); call_user_func($this->readDirCallBack);
} }
return $result; return $result;