velinizing

pescador/core.py

@@ -77,7 +77,6 @@ def __init__(self, streamer, *args, **kwargs):
         streamer : iterable or generator function
             Any generator function or object that is iterable when
             instantiated.
-
         args, kwargs
             Additional positional arguments or keyword arguments passed to
             ``streamer()`` if it is callable.
@@ -241,8 +240,7 @@ def __call__(self, max_iter=None, cycle=False):
             If `None`, attempt to exhaust the stream.
             For finite streams, call iterate again, or use `cycle=True` to
             force an infinite stream.
-
-        cycle: bool
+        cycle : bool
             If `True`, cycle indefinitely.
 
         Yields

pescador/maps.py

@@ -87,7 +87,6 @@ def buffer_stream(stream, buffer_size, partial=False, axis=None):
     >>> next(buf)
     {'x': array([0, 1, 2, 3, 4]), 'y': array([0, 1, 0, 1, 0])}
 
-
     If the iterates already have a batch index dimension, we can use it
     directly.  This can be useful when the streamers already generate
     partial batches that you want to combine, rather than singletons.
@@ -151,7 +150,6 @@ def tuples(stream, *keys):
     ----------
     stream : iterable
         Stream of data objects.
-
     *keys : strings
         Keys to use for ordering data.
 
@@ -185,11 +183,9 @@ def keras_tuples(stream, inputs=None, outputs=None):
     ----------
     stream : iterable
         Stream of data objects.
-
     inputs : string or iterable of strings, None
         Keys to use for ordered input data.
         If not specified, returns `None` in its place.
-
     outputs : string or iterable of strings, default=None
         Keys to use for ordered output data.
         If not specified, returns `None` in its place.

pescador/zmq_stream.py

@@ -133,17 +133,13 @@ def __init__(
         ----------
         streamer : `pescador.Streamer`
             The streamer object
-
         min_port : int > 0
         max_port : int > min_port
             The range of TCP ports to use
-
         max_tries : int > 0
             The maximum number of connection attempts to make
-
         copy : bool
             Set `True` to enable data copying
-
         timeout : [optional] number > 0
             Maximum time (in seconds) to wait before killing subprocesses.
             If `None`, then the streamer will wait indefinitely for