()
| 108 | } |
| 109 | |
| 110 | func (o *Observer) dispatchEvents() { |
| 111 | var sinks []EventSink |
| 112 | for { |
| 113 | select { |
| 114 | case sink := <-o.addSinkChan: |
| 115 | sinks = append(sinks, sink) |
| 116 | case evt := <-o.tunnelEventChan: |
| 117 | for _, sink := range sinks { |
| 118 | sink.OnTunnelEvent(evt) |
| 119 | } |
| 120 | } |
| 121 | } |
| 122 | } |
| 123 | |
| 124 | type EventSinkFunc func(event Event) |
| 125 |
no test coverage detected