@param {Number} lowerVersion
(lowerVersion)
| 327 | |
| 328 | /** @param {Number} lowerVersion */ |
| 329 | decreaseVersion(lowerVersion) { |
| 330 | // The response already has the max protocol version supported by the Cassandra host. |
| 331 | this.protocolVersion = lowerVersion; |
| 332 | this.encoder.setProtocolVersion(lowerVersion); |
| 333 | this._streamIds.setVersion(lowerVersion); |
| 334 | } |
| 335 | |
| 336 | /** |
| 337 | * Handle socket errors, if the socket is not readable invoke all pending callbacks |
no test coverage detected