Method _parse_args

functional/streams.py:48–74

(self, args, engine, error_message)

        )

    def _parse_args(self, args, engine, error_message):
        if len(args) == 0:
            raise TypeError(error_message.format(len(args)))
        if len(args) == 1:
            try:
                if type(args[0]).__name__ == "DataFrame":
                    import pandas

                    if isinstance(args[0], pandas.DataFrame):
                        return Sequence(
                            args[0].values,
                            engine=engine,
                            max_repr_items=self.max_repr_items,
                        )
            except ImportError:  # pragma: no cover
                pass

        if len(args) > 1:
            return Sequence(
                list(args), engine=engine, max_repr_items=self.max_repr_items
            )
        elif is_primitive(args[0]):
            return Sequence(
                [args[0]], engine=engine, max_repr_items=self.max_repr_items
            )
        else:
            return Sequence(args[0], engine=engine, max_repr_items=self.max_repr_items)

    def open(
        self,