diff --git a/lbrynet/lbrynet_daemon/LBRYDaemon.py b/lbrynet/lbrynet_daemon/LBRYDaemon.py
index 56e62bafc..687f23f73 100644
--- a/lbrynet/lbrynet_daemon/LBRYDaemon.py
+++ b/lbrynet/lbrynet_daemon/LBRYDaemon.py
@@ -1378,7 +1378,7 @@ class LBRYDaemon(jsonrpc.JSONRPC):
         reflector_server = random.choice(REFLECTOR_SERVERS)
         reflector_address, reflector_port = reflector_server[0], reflector_server[1]
         log.info("Start reflector client")
-        factory = reflector.LBRYBlobReflectorClient(
+        factory = reflector.LBRYBlobReflectorClientFactory(
             self.session.blob_manager,
             blob_hashes
         )
diff --git a/lbrynet/reflector/__init__.py b/lbrynet/reflector/__init__.py
index b2bfb4bdc..32291c0b0 100644
--- a/lbrynet/reflector/__init__.py
+++ b/lbrynet/reflector/__init__.py
@@ -1,2 +1,2 @@
 from lbrynet.reflector.server.server import ReflectorServerFactory as ServerFactory
-from lbrynet.reflector.client.client import LBRYFileReflectorClientFactory, LBRYBlobReflectorClient
+from lbrynet.reflector.client.client import LBRYFileReflectorClientFactory, LBRYBlobReflectorClientFactory
diff --git a/lbrynet/reflector/client/client.py b/lbrynet/reflector/client/client.py
index 16114b0a4..52ba3b271 100644
--- a/lbrynet/reflector/client/client.py
+++ b/lbrynet/reflector/client/client.py
@@ -329,6 +329,7 @@ class LBRYBlobReflectorClient(Protocol):
     def send_handshake(self):
         log.debug('Sending handshake')
         self.write(json.dumps({'version': 0}))
+        return defer.succeed(None)
 
     def parse_response(self, buff):
         try: