if isinstance(self._protocol, protocols.BufferedProtocol):
try:
- protocols._feed_data_to_bufferred_proto(self._protocol, data)
+ protocols._feed_data_to_buffered_proto(self._protocol, data)
except Exception as exc:
self._fatal_error(exc,
'Fatal error: protocol.buffer_updated() '
for usemv in [False, True]:
proto = Proto(1, usemv)
- protocols._feed_data_to_bufferred_proto(proto, b'12345')
+ protocols._feed_data_to_buffered_proto(proto, b'12345')
self.assertEqual(proto.data, b'12345')
proto = Proto(2, usemv)
- protocols._feed_data_to_bufferred_proto(proto, b'12345')
+ protocols._feed_data_to_buffered_proto(proto, b'12345')
self.assertEqual(proto.data, b'12345')
proto = Proto(2, usemv)
- protocols._feed_data_to_bufferred_proto(proto, b'1234')
+ protocols._feed_data_to_buffered_proto(proto, b'1234')
self.assertEqual(proto.data, b'1234')
proto = Proto(4, usemv)
- protocols._feed_data_to_bufferred_proto(proto, b'1234')
+ protocols._feed_data_to_buffered_proto(proto, b'1234')
self.assertEqual(proto.data, b'1234')
proto = Proto(100, usemv)
- protocols._feed_data_to_bufferred_proto(proto, b'12345')
+ protocols._feed_data_to_buffered_proto(proto, b'12345')
self.assertEqual(proto.data, b'12345')
proto = Proto(0, usemv)
with self.assertRaisesRegex(RuntimeError, 'empty buffer'):
- protocols._feed_data_to_bufferred_proto(proto, b'12345')
+ protocols._feed_data_to_buffered_proto(proto, b'12345')
def test_start_tls_client_reg_proto_1(self):
HELLO_MSG = b'1' * self.PAYLOAD_SIZE