From 3ab42b360610ef48e28651acf03a706ff259dae7 Mon Sep 17 00:00:00 2001
From: Janus <ysangkok@gmail.com>
Date: Thu, 15 Feb 2018 12:18:01 +0100
Subject: [PATCH] lightning: call coroutines on callback queue correctly

---
 lib/network.py | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/lib/network.py b/lib/network.py
index 8bb426f5..3bf478ad 100644
--- a/lib/network.py
+++ b/lib/network.py
@@ -588,7 +588,12 @@ class Network(util.DaemonThread):
             await self.on_get_header(interface, response)
 
         for callback in callbacks:
-            callback(response)
+           if asyncio.iscoroutinefunction(callback):
+               if response is None:
+                   print("RESPONSE IS NONE")
+               await callback(response)
+           else:
+               callback(response)
 
     def get_index(self, method, params):
         """ hashable index for subscriptions and cache"""