(dbID proto.DatabaseID, head int32, s *Service)
| 39 | } |
| 40 | |
| 41 | func newSubscribeWorker(dbID proto.DatabaseID, head int32, s *Service) *subscribeWorker { |
| 42 | return &subscribeWorker{ |
| 43 | dbID: dbID, |
| 44 | head: head, |
| 45 | s: s, |
| 46 | } |
| 47 | } |
| 48 | |
| 49 | func (w *subscribeWorker) run() { |
| 50 | defer w.wg.Done() |
no outgoing calls
no test coverage detected