subscribe installs the subscription in the event broadcast loop.
(sub *subscription)
| 187 | |
| 188 | // subscribe installs the subscription in the event broadcast loop. |
| 189 | func (es *EventSystem) subscribe(sub *subscription) *Subscription { |
| 190 | es.install <- sub |
| 191 | <-sub.installed |
| 192 | return &Subscription{ID: sub.id, f: sub, es: es} |
| 193 | } |
| 194 | |
| 195 | // SubscribeLogs creates a subscription that will write all logs matching the |
| 196 | // given criteria to the given logs channel. Default value for the from and to |
no outgoing calls
no test coverage detected