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

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

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