Atomic bomb

.gitignore

@@ -102,3 +102,7 @@ venv.bak/
 
 # mypy
 .mypy_cache/
+
+# IDEs
+.idea/
+.vscode/

.travis.yml

@@ -0,0 +1,20 @@
+language: python
+matrix:
+  include:
+    - python: 3.7
+      dist: xenial
+      sudo: true
+    - python: 3.6
+
+notifications:
+  email: false
+
+install:
+- pip install -U -e .[test]
+
+script:
+- flake8 --config=.flake8 cytoolz-stubs
+
+cache:
+  directories:
+  - "$HOME/.cache/pip"

cytoolz-stubs/__init__.pyi

@@ -0,0 +1,10 @@
+from typing import Any
+
+from .dicttoolz import *
+from .functoolz import *
+from .itertoolz import *
+from .recipes import *
+
+comp = compose
+flip: Any
+memoize: Any

cytoolz-stubs/_pipe.pyi

@@ -0,0 +1,146 @@
+from typing import Any, Callable, TypeVar, overload
+
+_T1 = TypeVar('_T1')
+_T2 = TypeVar('_T2')
+_T3 = TypeVar('_T3')
+_T4 = TypeVar('_T4')
+_T5 = TypeVar('_T5')
+_T6 = TypeVar('_T6')
+_T7 = TypeVar('_T7')
+_T8 = TypeVar('_T8')
+_T9 = TypeVar('_T9')
+_T10 = TypeVar('_T10')
+_T11 = TypeVar('_T11')
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+) -> _T2:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+) -> _T3:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+) -> _T4:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+        func4: Callable[[_T4], _T5],
+) -> _T5:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+        func4: Callable[[_T4], _T5],
+        func5: Callable[[_T5], _T6],
+) -> _T6:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+        func4: Callable[[_T4], _T5],
+        func5: Callable[[_T5], _T6],
+        func6: Callable[[_T6], _T7],
+) -> _T7:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+        func4: Callable[[_T4], _T5],
+        func5: Callable[[_T5], _T6],
+        func6: Callable[[_T6], _T7],
+        func7: Callable[[_T7], _T8],
+) -> _T8:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+        func4: Callable[[_T4], _T5],
+        func5: Callable[[_T5], _T6],
+        func6: Callable[[_T6], _T7],
+        func7: Callable[[_T7], _T8],
+        func8: Callable[[_T8], _T9],
+) -> _T9:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+        func4: Callable[[_T4], _T5],
+        func5: Callable[[_T5], _T6],
+        func6: Callable[[_T6], _T7],
+        func7: Callable[[_T7], _T8],
+        func8: Callable[[_T8], _T9],
+        func9: Callable[[_T9], _T10],
+) -> _T10:
+    ...
+
+
+@overload
+def pipe(
+        item: _T1,
+        func1: Callable[[_T1], _T2],
+        func2: Callable[[_T2], _T3],
+        func3: Callable[[_T3], _T4],
+        func4: Callable[[_T4], _T5],
+        func5: Callable[[_T5], _T6],
+        func6: Callable[[_T6], _T7],
+        func7: Callable[[_T7], _T8],
+        func8: Callable[[_T8], _T9],
+        func9: Callable[[_T9], _T10],
+        func10: Callable[[_T10], _T11],
+) -> _T11:
+    ...
+
+
+@overload
+def pipe(
+        item: Any,
+        *funcs: Callable[[Any], Any],
+) -> Any:
+    ...

cytoolz-stubs/curried/__init__.pyi

@@ -0,0 +1,49 @@
+# Stubs for cytoolz.curried (Python 3.6)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from typing import Any
+
+from .exceptions import merge, merge_with
+
+accumulate: Any
+assoc: Any
+assoc_in: Any
+cons: Any
+countby: Any
+do: Any
+drop: Any
+excepts: Any
+filter: Any
+get: Any
+get_in: Any
+groupby: Any
+interpose: Any
+itemfilter: Any
+itemmap: Any
+iterate: Any
+join: Any
+keyfilter: Any
+keymap: Any
+map: Any
+mapcat: Any
+nth: Any
+partial: Any
+partition: Any
+partition_all: Any
+partitionby: Any
+pluck: Any
+random_sample: Any
+reduce: Any
+reduceby: Any
+remove: Any
+sliding_window: Any
+sorted: Any
+tail: Any
+take: Any
+take_nth: Any
+topk: Any
+unique: Any
+update_in: Any
+valfilter: Any
+valmap: Any

cytoolz-stubs/curried/exceptions.pyi

@@ -0,0 +1,11 @@
+# Stubs for cytoolz.curried.exceptions (Python 3.6)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from typing import Any
+
+
+def merge(d: Any, *dicts: Any, **kwargs: Any) -> Any: ...
+
+
+def merge_with(func: Any, d: Any, *dicts: Any, **kwargs: Any) -> Any: ...

cytoolz-stubs/dicttoolz.pyi

@@ -0,0 +1,110 @@
+from typing import Any, Callable, Dict, Mapping, Sequence, Tuple, TypeVar, \
+    Union, overload
+
+_K = TypeVar('_K')
+_K1 = TypeVar('_K1')
+_V = TypeVar('_V')
+_V1 = TypeVar('_V1')
+
+
+def assoc(
+        d: Mapping[_K, _V],
+        key: _K1,
+        value: _V1,
+        factory: Callable[[], Dict[Union[_K, _K1], Union[_V, _V1]]] = dict
+) -> Dict[Union[_K, _K1], Union[_V, _V1]]: ...
+
+
+def assoc_in(
+        d: Mapping[_K, _V],
+        keys: Sequence[Any],
+        value: Any,
+        factory: Callable[[], Dict[_K, Any]] = dict
+) -> Dict[_K, Any]: ...
+
+
+def dissoc(
+        d: Mapping[_K, _V],
+        *keys: _K,
+) -> Dict[_K, _V]: ...
+
+
+def get_in(
+        keys: Sequence[Any],
+        coll: Mapping[_K, _V],
+        default: Any = None,
+        no_default: bool = False,
+) -> Any: ...
+
+
+def itemfilter(
+        predicate: Callable[[Tuple[_K, _V]], bool],
+        d: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K, _V]] = dict,
+) -> Dict[_K, _V]: ...
+
+
+def itemmap(
+        func: Callable[[Tuple[_K, _V]], Tuple[_K1, _V1]],
+        d: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K1, _V1]] = dict
+) -> Dict[_K1, _V1]: ...
+
+
+def keyfilter(
+        predicate: Callable[[_K], bool],
+        d: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K, _V]] = dict,
+) -> Dict[_K, _V]: ...
+
+
+def keymap(
+        func: Callable[[_K], _K1],
+        d: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K1, _V]] = dict
+) -> Dict[_K1, _V]: ...
+
+
+def merge(
+        *dicts: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K, _V]] = dict,
+) -> Dict[_K, _V]: ...
+
+
+@overload
+def merge_with(
+        func: Callable[[Sequence[_V]], _V1],
+        *dicts: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K, _V1]] = dict,
+) -> Dict[_K, _V1]: ...
+
+
+@overload
+def merge_with(
+        func: Callable[[Sequence[Any]], Any],
+        *dicts: Mapping[_K, Any],
+        factory: Callable[[], Dict[_K, Any]] = dict,
+) -> Dict[_K, Any]: ...
+
+
+def update_in(
+        d: Mapping[_K, _V],
+        keys: Sequence[Any],
+        func: Callable[[Any], Any],
+        default: Any = None,
+        factory: Callable[[], Dict[_K, Any]] = dict,
+) -> Dict[_K, Any]: ...
+
+
+def valfilter(
+        predicate: Callable[[_V], bool],
+        d: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K, _V]] = dict,
+) -> Dict[_K, _V]: ...
+
+
+def valmap(
+        func: Callable[[_V], _V1],
+        d: Mapping[_K, _V],
+        factory: Callable[[], Dict[_K, _V1]] = dict
+) -> Dict[_K, _V1]: ...