Skip to content

Commit 12c604b

Browse files
author
Zhen
committed
Change to @liutec's test
1 parent 7ba58d4 commit 12c604b

File tree

2 files changed

+6
-9
lines changed

2 files changed

+6
-9
lines changed

neo4j/bolt/connection.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -170,11 +170,7 @@ def __init__(self, address, sock, error_handler, **config):
170170
self.socket = sock
171171
self.error_handler = error_handler
172172
self.server = ServerInfo(SocketAddress.from_socket(sock))
173-
input_buffer_size = config.get("default_read_buffer_size")
174-
if input_buffer_size:
175-
self.input_buffer = ChunkedInputBuffer(capacity=input_buffer_size)
176-
else:
177-
self.input_buffer = ChunkedInputBuffer()
173+
self.input_buffer = ChunkedInputBuffer()
178174
self.output_buffer = ChunkedOutputBuffer()
179175
self.packer = Packer(self.output_buffer)
180176
self.unpacker = Unpacker()

test/integration/test_session.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -459,10 +459,11 @@ def test_errors_on_begin_transaction(self):
459459
session.begin_transaction()
460460

461461
def test_large_values(self):
462-
driver = GraphDatabase.driver(self.bolt_uri, auth=self.auth_token, default_read_buffer_size=16)
463-
session = driver.session()
464-
session.run("RETURN '{}'".format("A" * 251172))
465-
session.close()
462+
driver = GraphDatabase.driver(self.bolt_uri, auth=self.auth_token)
463+
for i in range(1, 7):
464+
session = driver.session()
465+
session.run("RETURN '{}'".format("A" * 2 ** 20))
466+
session.close()
466467
driver.close()
467468

468469
class TransactionCommittedTestCase(DirectIntegrationTestCase):

0 commit comments

Comments
 (0)