@@ -115,24 +115,6 @@ def wait_ready_prefix(popen, prefix):
115115 emulator_ready = popen .stderr .readline ().startswith (prefix )
116116
117117
118- def pubsub_wait_ready (popen ):
119- """Wait until the Pub / Sub emulator is ready to use.
120-
121- :type popen: :class:`subprocess.Popen`
122- :param popen: An open subprocess to interact with.
123- """
124- wait_ready_prefix (popen , _PS_READY_LINE_PREFIX )
125-
126-
127- def bigtable_wait_ready (popen ):
128- """Wait until the Bigtable emulator is ready to use.
129-
130- :type popen: :class:`subprocess.Popen`
131- :param popen: An open subprocess to interact with.
132- """
133- wait_ready_prefix (popen , _BT_READY_LINE_PREFIX )
134-
135-
136118def wait_ready (package , popen ):
137119 """Wait until the emulator is ready to use.
138120
@@ -148,9 +130,9 @@ def wait_ready(package, popen):
148130 if package == DATASTORE :
149131 datastore_wait_ready (popen )
150132 elif package == PUBSUB :
151- pubsub_wait_ready (popen )
133+ wait_ready_prefix (popen , _PS_READY_LINE_PREFIX )
152134 elif package == BIGTABLE :
153- bigtable_wait_ready (popen )
135+ wait_ready_prefix (popen , _BT_READY_LINE_PREFIX )
154136 else :
155137 raise KeyError ('Package not supported' , package )
156138
0 commit comments