46jPnk5Ng2BTImDBcNk2A1 changeset
| Changeset | 326162393062 (b) |
|---|---|
| Parent | None (a) |
| a | b | ||
|---|---|---|---|
| 0 | + | from couchdbkit import Server | |
| 0 | + | from couchdbkit.consumer import Consumer | |
| 0 | + | from time import sleep | |
| 0 | + | ||
| 0 | + | def print_event(*args, **kwargs): | |
| 0 | + | print('EVENT: %s - %s' % (args, kwargs)) | |
| 0 | + | ||
| 0 | + | db = Server(uri='http://localhost:5984') | |
| 0 | + | db.get_or_create_db('a_test_db') | |
| 0 | + | ||
| 0 | + | c = Consumer(db, backend="gevent") | |
| 0 | + | c.wait_async(print_event) | |
| 0 | + | sleep(1000) | |
| ... | |||
|
|