     func testPubSub() throws {
         let promise = Promise<RedisData>()
         
-        let listener = try makeClient()
+        let listener = try makeClient().blockingAwait()
         
         listener.subscribe(to: ["test", "test2"]).drain { data in
             promise.complete(data.message)
         }.catch(onError: promise.fail)
         
-        let publisher = try makeClient()
+        let publisher = try makeClient().blockingAwait()
         let listeners = try publisher.publish("hello", to: "test").blockingAwait(timeout: .seconds(1))
         
         XCTAssertEqual(listeners, 1)

    }
    
    func testCRUD() throws {
        let connection = try makeClient()
      
        _ = try! connection.delete(keys: ["*"]).blockingAwait(timeout: .seconds(2))
        

    }
    
    func testPipeline() throws {
        let connection = try makeClient().blockingAwait()
        _ = try connection.delete(keys: ["*"]).blockingAwait(timeout: .seconds(1))
        
        let pipeline = connection.makePipeline()
