diff --git a/packages/bolt-connection/src/bolt/bolt-protocol-v1.js b/packages/bolt-connection/src/bolt/bolt-protocol-v1.js index d04b33b4e..84c5deee7 100644 --- a/packages/bolt-connection/src/bolt/bolt-protocol-v1.js +++ b/packages/bolt-connection/src/bolt/bolt-protocol-v1.js @@ -499,6 +499,10 @@ export default class BoltProtocol { * @param {boolean} flush `true` if flush should happen after the message is written to the buffer. */ write (message, observer, flush) { + this._lastMessageSignature = message.signature + const messageStruct = new structure.Structure(message.signature, message.fields) + + this.packable(messageStruct)() const queued = this.queueObserverIfProtocolIsNotBroken(observer) if (queued) { @@ -506,11 +510,6 @@ export default class BoltProtocol { this._log.debug(`C: ${message}`) } - this._lastMessageSignature = message.signature - const messageStruct = new structure.Structure(message.signature, message.fields) - - this.packable(messageStruct)() - this._chunker.messageBoundary() if (flush) { this._chunker.flush() diff --git a/packages/neo4j-driver-deno/lib/bolt-connection/bolt/bolt-protocol-v1.js b/packages/neo4j-driver-deno/lib/bolt-connection/bolt/bolt-protocol-v1.js index a83f32f5a..cec3d5d06 100644 --- a/packages/neo4j-driver-deno/lib/bolt-connection/bolt/bolt-protocol-v1.js +++ b/packages/neo4j-driver-deno/lib/bolt-connection/bolt/bolt-protocol-v1.js @@ -499,6 +499,10 @@ export default class BoltProtocol { * @param {boolean} flush `true` if flush should happen after the message is written to the buffer. */ write (message, observer, flush) { + this._lastMessageSignature = message.signature + const messageStruct = new structure.Structure(message.signature, message.fields) + + this.packable(messageStruct)() const queued = this.queueObserverIfProtocolIsNotBroken(observer) if (queued) { @@ -506,11 +510,6 @@ export default class BoltProtocol { this._log.debug(`C: ${message}`) } - this._lastMessageSignature = message.signature - const messageStruct = new structure.Structure(message.signature, message.fields) - - this.packable(messageStruct)() - this._chunker.messageBoundary() if (flush) { this._chunker.flush()