Add a bunch of TODOs

dpkp · Oct 22, 2018 · 9bbf96a · 9bbf96a
1 parent 06fcca0
commit 9bbf96a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/kafka/producer/buffer.py b/kafka/producer/buffer.py
@@ -114,6 +114,7 @@ def queued(self):
         with self._lock:
             return len(self._waiters)
 
+# TODO should this be removed or finished?
 '''
 class BufferPool(object):
     """

diff --git a/kafka/protocol/struct.py b/kafka/protocol/struct.py
@@ -65,6 +65,7 @@ def __eq__(self, other):
                 return False
         return True
 
+# TODO should this be removed or finished?
 """
 class MetaStruct(type):
     def __new__(cls, clsname, bases, dct):

diff --git a/kafka/util.py b/kafka/util.py
@@ -67,6 +67,7 @@ class Dict(dict):
     pass
 
 
+# TODO what is the purpose of this? It has been unused since it was originally added
 def try_method_on_system_exit(obj, method, *args, **kwargs):
     def wrapper(_obj, _meth, *args, **kwargs):
         try:
-Original file line number
+Diff line change
@@ Expand Up / @@ -67,6 +67,7 @@ class Dict(dict): @@
         pass
+    # TODO what is the purpose of this? It has been unused since it was originally added
     def try_method_on_system_exit(obj, method, *args, **kwargs):
         def wrapper(_obj, _meth, *args, **kwargs):
             try:
@@ Expand Down @@