(row, meta, rowLength, flags, header)
| 111 | } |
| 112 | |
| 113 | setResultRow(row, meta, rowLength, flags, header) { |
| 114 | this._markAsCompleted(); |
| 115 | if (!this._rowCallback) { |
| 116 | return this.setResult(new errors.DriverInternalError('RowCallback not found for streaming frame handler')); |
| 117 | } |
| 118 | this._rowCallback(this._rowIndex++, row, rowLength); |
| 119 | if (this._rowIndex === rowLength) { |
| 120 | this._swapCallbackAndInvoke(null, { rowLength: rowLength, meta: meta, flags: flags }, header.bodyLength); |
| 121 | } |
| 122 | } |
| 123 | |
| 124 | /** |
| 125 | * Marks the current operation as timed out. |
no test coverage detected