(data)
| 179 | } |
| 180 | |
| 181 | publish(data) { |
| 182 | const subscribers = this._subscribers; |
| 183 | for (let i = 0; i < (subscribers?.length || 0); i++) { |
| 184 | try { |
| 185 | const onMessage = subscribers[i]; |
| 186 | onMessage(data, this.name); |
| 187 | } catch (err) { |
| 188 | process.nextTick(() => { |
| 189 | triggerUncaughtException(err, false); |
| 190 | }); |
| 191 | } |
| 192 | } |
| 193 | } |
| 194 | |
| 195 | withStoreScope(data) { |
| 196 | return new RunStoresScope(this, data); |
nothing calls this directly
no test coverage detected