even better logic

stream/stream.go

@@ -93,9 +93,9 @@ func (s *Stream) run_send() {
 	for {
 		select {
 		case sb := <-s.sub:
-			if sub, ok := s.subs.LoadOrStore(sb.id, sb); !ok {
+			sub, ok := s.subs.LoadOrStore(sb.id, sb)
 			sub.s.OnSubscribe(last.seq, last.val)
-			} else {
+			if ok {
 				sb.s.CloseWith(errors.New("duplicate subscription"))
 			}
 		case n := <-s.out: