def _activate(self):
        """Activates the stream."""
        if six.callable(self.streamer):
            # If it's a function, create the stream.
            self.stream_ = self.streamer(*(self.args), **(self.kwargs))

        else:
            # If it's iterable, use it directly.
            self.stream_ = iter(self.streamer)
def _activate ( self ) : if six . callable ( self . streamer ) : self . stream_ = self . streamer ( * ( self . args ) , ** ( self . kwargs ) ) else : self . stream_ = iter ( self . streamer )
Activates the stream.