pulsards client can not running?

[Bright Pan]

i use pulsards example for python3.5,

 for server:

from pulsar.apps.data import PulsarDS
if __name__ == '__main__':
   PulsarDS().start()

for client

>>> from pulsar.apps.data import create_store
>>> store = create_store('pulsar://localhost:6410')
>>> client = store.client()
>>> client.ping()
<generator object execute at 0x1114fd6d0>
>>> client.echo('Hello!')
<generator object execute at 0x1114fd645>

 the result for client.ping() is not True, Why?

[lsbardel]

Hi,

On Wednesday, March 16, 2016 at 12:08:37 PM UTC, Bright Pan wrote:

i use pulsards example for python3.5,

 

for client

>>> from pulsar.apps.data import create_store
>>> store = create_store('pulsar://localhost:6410')
>>> client = store.client()
>>> client.ping()
<generator object execute at 0x1114fd6d0>
>>> client.echo('Hello!')
<generator object execute at 0x1114fd645>

 the result for client.ping() is not True, Why?

 

Because the response is asynchronous.

You need to use these methods in a coroutine, alternatively in the shell you need to run the loop until the coroutine has finished:

>>> client._loop.run_until_complete(client.ping())
True

>>> client._loop.run_until_complete(client.echo('Hello!'))

b'Hello!'