             resp (.recv server 0)
             resp_msg (String. (.message resp))]
         (is (= req_msg resp_msg))))
+    (.close client)
+    (.close server)
     (.term context)))

        resp (.recv server 0)]
    (is (= task (.task resp)))
    (is (= req_msg (String. (.message resp))))
    (.term context)))    
    
(deftest test-server-delayed

        resp (.recv server 0)]
    (is (= task (.task resp)))
    (is (= req_msg (String. (.message resp))))
    (.close client)
    (.close server)
    (.term context)))    

(deftest test-batch
