Remove print statements
This commit is contained in:
parent
3d8efe0eb4
commit
f67efd7119
3 changed files with 0 additions and 27 deletions
|
|
@ -39,20 +39,13 @@ class EngineIO(LoggingMixin):
|
|||
|
||||
@property
|
||||
def _transport(self):
|
||||
print 't1'
|
||||
if self._connected:
|
||||
return self._transport_instance
|
||||
print 't2'
|
||||
self._engineIO_session = self._get_engineIO_session()
|
||||
print 't3'
|
||||
self._transport_instance = self._negotiate_transport()
|
||||
print 't4'
|
||||
self._connect_namespaces()
|
||||
print 't5'
|
||||
self._connected = True
|
||||
print 't6 starting heartbeat'
|
||||
self._reset_heartbeat()
|
||||
print 't7'
|
||||
return self._transport_instance
|
||||
|
||||
def _get_engineIO_session(self):
|
||||
|
|
@ -156,7 +149,6 @@ class EngineIO(LoggingMixin):
|
|||
self._transport.send_packet(engineIO_packet_type, engineIO_packet_data)
|
||||
|
||||
def _message(self, engineIO_packet_data):
|
||||
print('_message %s' % str(engineIO_packet_data))
|
||||
engineIO_packet_type = 4
|
||||
self._transport.send_packet(engineIO_packet_type, engineIO_packet_data)
|
||||
|
||||
|
|
@ -207,7 +199,6 @@ class EngineIO(LoggingMixin):
|
|||
|
||||
def _process_packet(self, packet):
|
||||
engineIO_packet_type, engineIO_packet_data = packet
|
||||
print 'engineIO_packet_data=%s' % engineIO_packet_data
|
||||
# Launch callbacks
|
||||
namespace = self.get_namespace()
|
||||
try:
|
||||
|
|
@ -224,8 +215,6 @@ class EngineIO(LoggingMixin):
|
|||
raise PacketError(
|
||||
'unexpected engine.io packet type (%s)' % engineIO_packet_type)
|
||||
delegate(engineIO_packet_data, namespace._find_packet_callback)
|
||||
print '*** in engine.io, engineIO_packet_type=%s' % engineIO_packet_type
|
||||
print '*** in engine.io, engineIO_packet_data=%s' % engineIO_packet_data
|
||||
if engineIO_packet_type is 4:
|
||||
return engineIO_packet_data
|
||||
|
||||
|
|
@ -341,20 +330,13 @@ class SocketIO(EngineIO):
|
|||
pass
|
||||
|
||||
def emit(self, event, *args, **kw):
|
||||
print 'z1'
|
||||
path = kw.get('path', '')
|
||||
print 'z2'
|
||||
callback, args = find_callback(args, kw)
|
||||
print 'z3'
|
||||
ack_id = self._set_ack_callback(callback) if callback else None
|
||||
print 'z4'
|
||||
args = [event] + list(args)
|
||||
socketIO_packet_type = 2
|
||||
print 'z5 path=%s ack_id=%s args=%s' % (path, ack_id, str(args))
|
||||
socketIO_packet_data = format_socketIO_packet_data(path, ack_id, args)
|
||||
print 'z6 emitting %s' % str(socketIO_packet_data)
|
||||
self._message(str(socketIO_packet_type) + socketIO_packet_data)
|
||||
print 'z7'
|
||||
|
||||
def send(self, data='', callback=None):
|
||||
args = [data]
|
||||
|
|
@ -382,7 +364,6 @@ class SocketIO(EngineIO):
|
|||
|
||||
def _process_packet(self, packet):
|
||||
engineIO_packet_data = super(SocketIO, self)._process_packet(packet)
|
||||
print '*** in socket.io, engineIO_packet_data=%s' % engineIO_packet_data
|
||||
if engineIO_packet_data is None:
|
||||
return
|
||||
socketIO_packet_type = int(get_character(engineIO_packet_data, 0))
|
||||
|
|
|
|||
|
|
@ -59,7 +59,6 @@ def format_socketIO_packet_data(path=None, ack_id=None, args=None):
|
|||
socketIO_packet_data = str(ack_id) + socketIO_packet_data
|
||||
if path:
|
||||
socketIO_packet_data = path + ',' + socketIO_packet_data
|
||||
print 'format_socketIO_packet_data = %s' % socketIO_packet_data
|
||||
return socketIO_packet_data
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -39,9 +39,7 @@ class BaseMixin(object):
|
|||
def test_emit(self):
|
||||
'Emit'
|
||||
namespace = self.socketIO.define(Namespace)
|
||||
print 'a'
|
||||
self.socketIO.emit('emit')
|
||||
print 'b'
|
||||
self.socketIO.wait(self.wait_time_in_seconds)
|
||||
self.assertEqual(namespace.args_by_event, {
|
||||
'emit_response': (),
|
||||
|
|
@ -171,26 +169,21 @@ class Test_XHR_PollingTransport(BaseMixin, TestCase):
|
|||
class Namespace(LoggingNamespace):
|
||||
|
||||
def initialize(self):
|
||||
print('xxx initialize')
|
||||
self.called_on_disconnect = False
|
||||
self.args_by_event = {}
|
||||
self.response = None
|
||||
|
||||
def on_disconnect(self):
|
||||
print('xxx on_disconnect')
|
||||
self.called_on_disconnect = True
|
||||
|
||||
def on_wait_with_disconnect_response(self):
|
||||
print('xxx on_wait_with_disconnect_response')
|
||||
self.disconnect()
|
||||
|
||||
def on_event(self, event, *args):
|
||||
print('xxx on_event')
|
||||
callback, args = find_callback(args)
|
||||
if callback:
|
||||
callback(*args)
|
||||
self.args_by_event[event] = args
|
||||
|
||||
def on_message(self, data):
|
||||
print('xxx on_message')
|
||||
self.response = data
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue