Skip to content

Commit d16c3fb

Browse files
committed
Fix merge issues
1 parent 302ff74 commit d16c3fb

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

packages/core/src/internal/connection-holder.ts

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -178,11 +178,7 @@ class ConnectionHolder implements ConnectionHolderInterface {
178178
return this._connectionPromise
179179
}
180180

181-
<<<<<<< HEAD
182-
close (): Promise<null | Connection> {
183-
=======
184-
close(hasTx?: boolean): Promise<void | Connection> {
185-
>>>>>>> Sending reset if there is a tx going on
181+
close (hasTx?: boolean): Promise<null | Connection> {
186182
if (this._referenceCount === 0) {
187183
return this._connectionPromise
188184
}
@@ -197,11 +193,11 @@ class ConnectionHolder implements ConnectionHolderInterface {
197193
* @return {Promise} - promise resolved then connection is returned to the pool.
198194
* @private
199195
*/
200-
private _releaseConnection (): Promise<Connection | null> {
196+
private _releaseConnection (hasTx?: boolean): Promise<Connection | null> {
201197
this._connectionPromise = this._connectionPromise
202198
.then((connection?: Connection|null) => {
203199
if (connection != null) {
204-
if (connection.isOpen() && (connection.hasOngoingObservableRequests() || hasTx)) {
200+
if (connection.isOpen() && (connection.hasOngoingObservableRequests() || hasTx === true)) {
205201
return connection
206202
.resetAndFlush()
207203
.catch(ignoreError)

0 commit comments

Comments
 (0)