@@ -100,8 +100,15 @@ discard block |
||
| 100 | 100 | } |
| 101 | 101 | |
| 102 | 102 | |
| 103 | + /** |
|
| 104 | + * @param callable $callback |
|
| 105 | + */ |
|
| 103 | 106 | protected function retrieveSessionIds($callback = null) {
|
| 104 | 107 | $this->session->call(self::SESSION_LIST_TOPIC, [])->then( |
| 108 | + |
|
| 109 | + /** |
|
| 110 | + * @param callable $res |
|
| 111 | + */ |
|
| 105 | 112 | function ($res)use($callback){
|
| 106 | 113 | $this->sessionIds = $res[0]; |
| 107 | 114 | $this->emit('list', [$this->sessionIds]);
|
@@ -109,6 +116,10 @@ discard block |
||
| 109 | 116 | $callback($this->sessionIds); |
| 110 | 117 | } |
| 111 | 118 | }, |
| 119 | + |
|
| 120 | + /** |
|
| 121 | + * @param callable $error |
|
| 122 | + */ |
|
| 112 | 123 | function ($error) {
|
| 113 | 124 | $this->emit('error', [$error]);
|
| 114 | 125 | } |
@@ -66,7 +66,7 @@ |
||
| 66 | 66 | public function getSessionIds(callable $callback) { |
| 67 | 67 | if(!count($this->sessionIds)){ |
| 68 | 68 | $this->retrieveSessionIds($callback); |
| 69 | - }else{ |
|
| 69 | + } else{ |
|
| 70 | 70 | $callback($this->sessionIds); |
| 71 | 71 | } |
| 72 | 72 | } |