Merge pull request #18 from MoonVision/master

Fix debug log/print with tuples
dbrattli · Nov 9, 2020 · 1140d2d · 1140d2d
2 parents 3c40b2d + f5f150a
commit 1140d2d
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/aioreactive/operators/from_iterable.py b/aioreactive/operators/from_iterable.py
@@ -29,7 +29,7 @@ async def worker() -> None:
             log.debug("sync_worker()")
             for value in self.iterable:
                 try:
-                    log.debug("sync_worker. asending: %s" % str(value))
+                    log.debug("sync_worker. asending: %s", value)
                     await observer.asend(value)
                 except Exception as ex:
                     await observer.athrow(ex)

diff --git a/aioreactive/operators/merge.py b/aioreactive/operators/merge.py
@@ -45,7 +45,7 @@ async def cancel(self, sub=None) -> None:
             self._inner_subs = {}
 
         async def asend_core(self, stream: AsyncObservable) -> None:
-            log.debug("Merge.Sink:asend_core(%s)" % stream)
+            log.debug("Merge.Sink:asend_core(%s)", stream)
 
             inner_stream = Merge.Sink.InnerStream()
             inner_sub = await chain(inner_stream, self._observer)  # type: AsyncDisposable

diff --git a/aioreactive/operators/switch_latest.py b/aioreactive/operators/switch_latest.py
@@ -34,7 +34,7 @@ def done(self, sub=None) -> None:
             self.latest = 0
 
         async def asend(self, stream) -> None:
-            log.debug("SwitchLatest._:send(%s)" % stream)
+            log.debug("SwitchLatest._:send(%s)", stream)
             inner_observer = await chain(SwitchLatest.Sink.Inner(self), self._observer)
 
             self._latest = id(inner_observer)

diff --git a/aioreactive/testing/observer.py b/aioreactive/testing/observer.py
@@ -31,7 +31,7 @@ def __init__(self, send=anoop, throw=anoop, close=anoop):
         self._close = close
 
     async def asend_core(self, value: T):
-        print("AsyncAnonymousObserver:asend_core(%s)" % value)
+        print("AsyncAnonymousObserver:asend_core(%s)" % (value,))
         time = self._loop.time()
         self._values.append((time, value))