The one starting server is responsible to make sure it started

Refs #16

grpc4bmi/bmi_client_docker.py

@@ -3,6 +3,7 @@
 import errno
 
 import docker
+from wait_for_port import wait_for_port
 
 from grpc4bmi.bmi_grpc_client import BmiClient
 
@@ -42,6 +43,7 @@ def __init__(self, image, image_port=50051, host=None, input_dir=None, output_di
                                                user=user,
                                                remove=True,
                                                detach=True)
+        wait_for_port(port=port, host='localhost' if host is None else host)
         super(BmiClientDocker, self).__init__(BmiClient.create_grpc_channel(port=port, host=host))
 
     def __del__(self):

grpc4bmi/bmi_client_subproc.py

@@ -2,6 +2,8 @@
 import subprocess
 import time
 
+from wait_for_port import wait_for_port
+
 from grpc4bmi.bmi_grpc_client import BmiClient
 
 
@@ -19,7 +21,7 @@ def __init__(self, module_name):
         port_options = ["--port", str(port)]
         self.pipe = subprocess.Popen(["run-bmi-server"] + name_options + port_options, env=dict(os.environ),
                                      stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-        time.sleep(1)
+        wait_for_port(port=port, host='localhost' if host is None else host)
         super(BmiClientSubProcess, self).__init__(BmiClient.create_grpc_channel(port=port, host=host))
 
     def __del__(self):

setup.py

@@ -31,6 +31,7 @@ def read(fname):
           'futures; python_version == "2.7"',
           "docker",
           "basic-modeling-interface",
+          "wait_for_port",
       ],
       extras_require={
           'R': ['rpy2'],