tidal /
WampWatch
| @@ 103-117 (lines=15) @@ | ||
| 100 | } |
|
| 101 | ||
| 102 | ||
| 103 | protected function retrieveSessionIds($callback = null) { |
|
| 104 | $this->session->call(self::SESSION_LIST_TOPIC, [])->then( |
|
| 105 | function ($res)use($callback){ |
|
| 106 | $this->sessionIds = $res[0]; |
|
| 107 | $this->emit('list', [$this->sessionIds]); |
|
| 108 | if($callback){ |
|
| 109 | $callback($this->sessionIds); |
|
| 110 | } |
|
| 111 | }, |
|
| 112 | function ($error) { |
|
| 113 | $this->emit('error', [$error]); |
|
| 114 | } |
|
| 115 | ); |
|
| 116 | ||
| 117 | } |
|
| 118 | ||
| 119 | } |
|
| 120 | ||
| @@ 140-154 (lines=15) @@ | ||
| 137 | ); |
|
| 138 | } |
|
| 139 | ||
| 140 | protected function retrieveSubscriptionIds($callback = null) { |
|
| 141 | return $this->session->call(self::SUBSCRIPTION_LIST_TOPIC, [])->then( |
|
| 142 | function ($res)use($callback){ |
|
| 143 | $this->subscriptionIds = $res[0]; |
|
| 144 | $this->emit('list', [$this->subscriptionIds]); |
|
| 145 | if($callback){ |
|
| 146 | $callback($this->subscriptionIds); |
|
| 147 | } |
|
| 148 | }, |
|
| 149 | function ($error) { |
|
| 150 | $this->emit('error', [$error]); |
|
| 151 | } |
|
| 152 | ); |
|
| 153 | ||
| 154 | } |
|
| 155 | ||
| 156 | protected function getList() { |
|
| 157 | return $this->subscriptionIds; |
|
