Finished channel is already closed

hub/subscription.go

@@ -52,6 +52,5 @@ func (s *Subscription) Done() <-chan struct{} {
 }
 
 func (s *Subscription) Close() {
-	close(s.result)
 	close(s.done)
 }

server.go

@@ -86,7 +86,6 @@ func subHandler(w http.ResponseWriter, r *http.Request) {
 		select {
 		case <-disconnected:
 			sub.Close()
-			close(finished)
 		case <-finished:
 		}
 	}()