@@ -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 | } |
@@ -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 | } |