Fix deepsource issues

Author: garlontas

pystreamapi/_streams/__base_stream.py

@@ -21,6 +21,10 @@
 
 
 def _operation(func):
+    """
+    Decorator to execute all the processes in the queue before executing the decorated function.
+    To be applied to intermediate operations.
+    """
     @functools.wraps(func)
     def wrapper(*args, **kwargs):
         self: BaseStream = args[0]
@@ -65,9 +69,11 @@ def __init__(self, source: Iterable[K]):
         self._open = True
 
     def _close(self):
+        """Close the stream."""
         self._open = False
 
     def _verify_open(self):
+        """Verify if stream is open. If not, raise an exception."""
         if not self._open:
             raise RuntimeError("The stream has been closed")
 
@@ -233,7 +239,6 @@ def peek(self, action: Callable) -> 'BaseStream[_V]':
     def _peek(self, action: Callable):
         """Implementation of peek. Should be implemented by subclasses."""
 
-
     @_operation
     def reversed(self) -> 'BaseStream[_V]':
         """

pystreamapi/_streams/numeric/__numeric_base_stream.py

@@ -21,6 +21,7 @@ def interquartile_range(self) -> Union[float, int, None]:
         return self._interquartile_range()
 
     def _interquartile_range(self):
+        """Implementation of the interquartile range calculation"""
         return self._third_quartile() - self._first_quartile() if len(self._source) > 0 else None
 
     @terminal
@@ -32,6 +33,7 @@ def first_quartile(self) -> Union[float, int, None]:
         return self._first_quartile()
 
     def _first_quartile(self):
+        """Implementation of the first quartile calculation"""
         self._source = sorted(self._source)
         return self.__median(self._source[:(len(self._source)) // 2])
 
@@ -99,5 +101,6 @@ def third_quartile(self) -> Union[float, int, None]:
         return self._third_quartile()
 
     def _third_quartile(self):
+        """Implementation of the third quartile calculation"""
         self._source = sorted(self._source)
         return self.__median(self._source[(len(self._source) + 1) // 2:])