Restoring authorship annotation for Aleksandr <ivansduck@gmail.com>. Commit 1 of 2.

1 files changed, 97 insertions, 97 deletions

diff --git a/library/python/func/__init__.py b/library/python/func/__init__.py
index 7424361635..e37ea95c7c 100644
--- a/library/python/func/__init__.py
+++ b/library/python/func/__init__.py
@@ -1,6 +1,6 @@
 import functools
-import threading
-import collections
+import threading 
+import collections 
 
 
 def map0(func, value):
@@ -20,12 +20,12 @@ class _Result(object):
 def lazy(func):
     result = _Result()
 
-    @functools.wraps(func)
-    def wrapper(*args):
+    @functools.wraps(func) 
+    def wrapper(*args): 
         try:
             return result.result
         except AttributeError:
-            result.result = func(*args)
+            result.result = func(*args) 
 
         return result.result
 
@@ -64,54 +64,54 @@ class lazy_classproperty(object):
         return getattr(owner, attr_name)
 
 
-def memoize(limit=0, thread_local=False):
-    assert limit >= 0
-
+def memoize(limit=0, thread_local=False): 
+    assert limit >= 0 
+ 
     def decorator(func):
-        memory = {}
-        lock = threading.Lock()
-
-        if limit:
-            keys = collections.deque()
-
-            def get(args):
-                try:
-                    return memory[args]
-                except KeyError:
-                    with lock:
-                        if args not in memory:
-                            fargs = args[-1]
-                            memory[args] = func(*fargs)
-                            keys.append(args)
-                            if len(keys) > limit:
-                                del memory[keys.popleft()]
-                        return memory[args]
-
-        else:
-
-            def get(args):
-                if args not in memory:
-                    with lock:
-                        if args not in memory:
-                            fargs = args[-1]
-                            memory[args] = func(*fargs)
-                return memory[args]
-
-        if thread_local:
-
-            @functools.wraps(func)
-            def wrapper(*args):
-                th = threading.current_thread()
-                return get((th.ident, th.name, args))
-
-        else:
-
-            @functools.wraps(func)
-            def wrapper(*args):
-                return get(('', '', args))
-
-        return wrapper
-
+        memory = {} 
+        lock = threading.Lock() 
+ 
+        if limit: 
+            keys = collections.deque() 
+ 
+            def get(args): 
+                try: 
+                    return memory[args] 
+                except KeyError: 
+                    with lock: 
+                        if args not in memory: 
+                            fargs = args[-1] 
+                            memory[args] = func(*fargs) 
+                            keys.append(args) 
+                            if len(keys) > limit: 
+                                del memory[keys.popleft()] 
+                        return memory[args] 
+
+        else: 
+ 
+            def get(args): 
+                if args not in memory: 
+                    with lock: 
+                        if args not in memory: 
+                            fargs = args[-1] 
+                            memory[args] = func(*fargs) 
+                return memory[args] 
+ 
+        if thread_local: 
+ 
+            @functools.wraps(func) 
+            def wrapper(*args): 
+                th = threading.current_thread() 
+                return get((th.ident, th.name, args)) 
+ 
+        else: 
+ 
+            @functools.wraps(func) 
+            def wrapper(*args): 
+                return get(('', '', args)) 
+ 
+        return wrapper 
+ 
     return decorator
 
 
@@ -119,52 +119,52 @@ def memoize(limit=0, thread_local=False):
 def compose(*functions):
     def compose2(f, g):
         return lambda x: f(g(x))
-
+ 
     return functools.reduce(compose2, functions, lambda x: x)
-
-
-class Singleton(type):
-    _instances = {}
-
-    def __call__(cls, *args, **kwargs):
-        if cls not in cls._instances:
-            cls._instances[cls] = super(Singleton, cls).__call__(*args, **kwargs)
-        return cls._instances[cls]
-
-
-def stable_uniq(it):
-    seen = set()
-    res = []
-    for e in it:
-        if e not in seen:
-            res.append(e)
-            seen.add(e)
-    return res
-
-
-def first(it):
-    for d in it:
-        if d:
-            return d
-
-
-def split(data, func):
-    l, r = [], []
-    for e in data:
-        if func(e):
-            l.append(e)
-        else:
-            r.append(e)
-    return l, r
+ 
+ 
+class Singleton(type): 
+    _instances = {} 
+ 
+    def __call__(cls, *args, **kwargs): 
+        if cls not in cls._instances: 
+            cls._instances[cls] = super(Singleton, cls).__call__(*args, **kwargs) 
+        return cls._instances[cls] 
+ 
+ 
+def stable_uniq(it): 
+    seen = set() 
+    res = [] 
+    for e in it: 
+        if e not in seen: 
+            res.append(e) 
+            seen.add(e) 
+    return res 
+ 
+ 
+def first(it): 
+    for d in it: 
+        if d: 
+            return d 
+ 
+ 
+def split(data, func): 
+    l, r = [], [] 
+    for e in data: 
+        if func(e): 
+            l.append(e) 
+        else: 
+            r.append(e) 
+    return l, r 
 
 
 def flatten_dict(dd, separator='.', prefix=''):
-    return (
-        {
-            prefix + separator + k if prefix else k: v
-            for kk, vv in dd.items()
-            for k, v in flatten_dict(vv, separator, kk).items()
-        }
-        if isinstance(dd, dict)
-        else {prefix: dd}
-    )
+    return ( 
+        { 
+            prefix + separator + k if prefix else k: v 
+            for kk, vv in dd.items() 
+            for k, v in flatten_dict(vv, separator, kk).items() 
+        } 
+        if isinstance(dd, dict) 
+        else {prefix: dd} 
+    )