aboutsummaryrefslogtreecommitdiffstats
path: root/python-tornado
diff options
context:
space:
mode:
Diffstat (limited to 'python-tornado')
-rw-r--r--python-tornado/examples/history.py5
-rw-r--r--python-tornado/examples/publish.py5
-rw-r--r--python-tornado/examples/subscribe.py11
3 files changed, 13 insertions, 8 deletions
diff --git a/python-tornado/examples/history.py b/python-tornado/examples/history.py
index da3d6a5..daf1c6e 100644
--- a/python-tornado/examples/history.py
+++ b/python-tornado/examples/history.py
@@ -20,13 +20,14 @@ ssl_on = len(sys.argv) > 5 and bool(sys.argv[5]) or False
## -----------------------------------------------------------------------
pubnub = Pubnub(publish_key=publish_key, subscribe_key=subscribe_key,
secret_key=secret_key, cipher_key=cipher_key, ssl_on=ssl_on)
-channel = 'a'
+channel = 'a'
# Asynchronous usage
+
def callback(message):
print(message)
-pubnub.history(channel, count=2 , callback=callback, error=callback)
+pubnub.history(channel, count=2, callback=callback, error=callback)
pubnub.start()
diff --git a/python-tornado/examples/publish.py b/python-tornado/examples/publish.py
index 4e662fd..04e88fd 100644
--- a/python-tornado/examples/publish.py
+++ b/python-tornado/examples/publish.py
@@ -20,11 +20,12 @@ ssl_on = len(sys.argv) > 5 and bool(sys.argv[5]) or False
## -----------------------------------------------------------------------
pubnub = Pubnub(publish_key=publish_key, subscribe_key=subscribe_key,
secret_key=secret_key, cipher_key=cipher_key, ssl_on=ssl_on)
-channel = 'hello_world'
-message = 'Hello World !!!'
+channel = 'hello_world'
+message = 'Hello World !!!'
# Asynchronous usage
+
def callback(message):
print(message)
diff --git a/python-tornado/examples/subscribe.py b/python-tornado/examples/subscribe.py
index 9288836..72f0fc1 100644
--- a/python-tornado/examples/subscribe.py
+++ b/python-tornado/examples/subscribe.py
@@ -21,28 +21,31 @@ ssl_on = len(sys.argv) > 5 and bool(sys.argv[5]) or False
pubnub = Pubnub(publish_key=publish_key, subscribe_key=subscribe_key,
secret_key=secret_key, cipher_key=cipher_key, ssl_on=ssl_on)
-channel = 'a'
-
+channel = 'a'
# Asynchronous usage
-
def callback(message, channel):
print(message)
+
def error(message):
print("ERROR : " + str(message))
+
def connect(message):
print("CONNECTED")
+
def reconnect(message):
print("RECONNECTED")
+
def disconnect(message):
print("DISCONNECTED")
-pubnub.subscribe(channel, callback=callback, error=callback, connect=connect, reconnect=reconnect, disconnect=disconnect)
+pubnub.subscribe(channel, callback=callback, error=callback,
+ connect=connect, reconnect=reconnect, disconnect=disconnect)
pubnub.start()