code: func (s *Server) OnStart() error {
  	go s.loop(state{
  		queries: make(map[query.Query]map[string]chan interface{}),
  		clients: make(map[string]map[query.Query]struct{}),
  	})
  	return nil
  }
docs: // OnStart implements Service.OnStart by starting the server.