aboutsummaryrefslogtreecommitdiffstats
path: root/python/tests/subscribe-test.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/tests/subscribe-test.py')
-rwxr-xr-xpython/tests/subscribe-test.py19
1 files changed, 9 insertions, 10 deletions
diff --git a/python/tests/subscribe-test.py b/python/tests/subscribe-test.py
index 0d4c65e..be4a416 100755
--- a/python/tests/subscribe-test.py
+++ b/python/tests/subscribe-test.py
@@ -38,31 +38,31 @@ received = 0
## Subscribe Example
## -----------------------------------------------------------------------
def message_received(message):
- print message
+ print(message)
def check_received(message):
global current
global errors
global received
- print message
- print current
+ print(message)
+ print(current)
if message <= current:
- print 'ERROR'
+ print('ERROR')
#sys.exit()
errors += 1
else:
received += 1
- print 'active thread count : ', threading.activeCount()
- print 'errors = ' , errors
- print current_thread().getName(), ' , ', 'received = ', received
+ print('active thread count : ' + str( threading.activeCount()))
+ print('errors = ' + str(errors))
+ print(current_thread().getName() + ' , ' + 'received = ' + str(received))
if received != message:
- print '********** MISSED **************** ', message - received
+ print('********** MISSED **************** ' + str( message - received ))
current = message
def connected_test(ch) :
- print 'Connected' , ch
+ print('Connected ' + ch)
def connected(ch) :
pass
@@ -103,7 +103,6 @@ def subscribe(channel):
})
-print threading.activeCount()
pubnub.timeout(15,cb1)