Lines Matching refs:request
53 request = _create_request('')
54 msgutil.send_message(request, 'Hello')
55 self.assertEqual('\x00Hello\xff', request.connection.written_data())
58 request = _create_request('')
59 msgutil.send_message(request, u'\u65e5')
62 request.connection.written_data())
65 request = _create_request('\x00Hello\xff\x00World!\xff')
66 self.assertEqual('Hello', msgutil.receive_message(request))
67 self.assertEqual('World!', msgutil.receive_message(request))
70 request = _create_request('\x00\xe6\x9c\xac\xff')
72 self.assertEqual(u'\u672c', msgutil.receive_message(request))
76 request = _create_request('\x00\x80\x81\xff')
79 self.assertEqual(u'\ufffd\ufffd', msgutil.receive_message(request))
82 request = _create_request('\x80\x06IGNORE\x00Hello\xff'
84 self.assertEqual('Hello', msgutil.receive_message(request))
85 self.assertEqual('World!', msgutil.receive_message(request))
94 request = _create_request('abcdefg')
95 self.assertEqual('abc', msgutil._receive_bytes(request, 3))
96 self.assertEqual('defg', msgutil._receive_bytes(request, 4))
99 request = _create_request('abcXdefgX')
100 self.assertEqual('abc', msgutil._read_until(request, 'X'))
101 self.assertEqual('defg', msgutil._read_until(request, 'X'))
106 request = _create_blocking_request()
107 receiver = msgutil.MessageReceiver(request)
111 request.connection.put_bytes('\x00Hello!\xff')
119 request = _create_blocking_request()
120 receiver = msgutil.MessageReceiver(request, onmessage_handler)
122 request.connection.put_bytes('\x00Hello!\xff')
128 request = _create_blocking_request()
129 sender = msgutil.MessageSender(request)
132 self.assertEqual('\x00World\xff', request.connection.written_data())
136 # request.connection.written_data() cannot be used here because
141 request = _create_blocking_request()
142 request.connection.write = write
144 sender = msgutil.MessageSender(request)
