+import Async
 import Dispatch
 import TCP
 import XCTest


            let string = String(data: response, encoding: .utf8)
            XCTAssert(string?.contains("HTTP/1.0 400 Bad Request") == true)
            group.leave()
        }
        read.resume()

        XCTAssertNotNil([read, write])
        group.wait()
    }

    func testBind() throws {

        try server.listen()

        let queue = DispatchQueue(label: "codes.vapor.test")
        let promise = Promise<Void>()

        var accepted: (Socket, DispatchSourceRead)?

