added missing validation in process()

jucardi · jucardi · commit 35109febc49f · 2018-11-26T18:42:14.000-08:00
diff --git a/streams/stream_impl.go b/streams/stream_impl.go
@@ -330,7 +330,10 @@ func (s *Stream) process() IIterable {
 		return s.parallelProcess(s.threads)
 	}
 
-	var iterable = s.iterable
+	iterable := s.iterable
+	if iterable == nil {
+		return nil
+	}
 	iterable = s.filter(iterable)
 	iterable = s.sort(iterable)
 	return iterable
