neo4j
diff --git a/‎README.md
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions b/‎README.md
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/‎packages/neo4j-driver/README.md
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions b/‎packages/neo4j-driver/README.md
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/‎packages/neo4j-driver/package-lock.json
Copy file name to clipboard
+15-18Lines changed: 15 additions & 18 deletions b/‎packages/neo4j-driver/package-lock.json
Copy file name to clipboard
+15-18Lines changed: 15 additions & 18 deletions
diff --git a/‎packages/neo4j-driver/package.json
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎packages/neo4j-driver/package.json
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/neo4j-driver/src/internal/retry-logic-rx.js
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions b/‎packages/neo4j-driver/src/internal/retry-logic-rx.js
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/‎packages/neo4j-driver/src/result-rx.js
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions b/‎packages/neo4j-driver/src/result-rx.js
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/‎packages/neo4j-driver/src/session-rx.js
Copy file name to clipboard
+5-5Lines changed: 5 additions & 5 deletions b/‎packages/neo4j-driver/src/session-rx.js
Copy file name to clipboard
+5-5Lines changed: 5 additions & 5 deletions
diff --git a/‎packages/neo4j-driver/test/internal/retry-logic-rx.test.js
Copy file name to clipboard
+2-1Lines changed: 2 additions & 1 deletion b/‎packages/neo4j-driver/test/internal/retry-logic-rx.test.js
Copy file name to clipboard
+2-1Lines changed: 2 additions & 1 deletion
diff --git a/‎packages/neo4j-driver/test/rx/nested-statements.test.js
Copy file name to clipboard
+8-8Lines changed: 8 additions & 8 deletions b/‎packages/neo4j-driver/test/rx/nested-statements.test.js
Copy file name to clipboard
+8-8Lines changed: 8 additions & 8 deletions
diff --git a/‎packages/neo4j-driver/test/rx/session.test.js
Copy file name to clipboard
+4-3Lines changed: 4 additions & 3 deletions b/‎packages/neo4j-driver/test/rx/session.test.js
Copy file name to clipboard
+4-3Lines changed: 4 additions & 3 deletions
@@ -222,7 +222,7 @@ rxSession
   .records()
   .pipe(
     map(record => record.get('name')),
-    concat(rxSession.close())
+    concatWith(rxSession.close())
   )
   .subscribe({
     next: data => console.log(data),
@@ -373,8 +373,8 @@ try {
 rxSession
   .beginTransaction()
   .pipe(
-    flatMap(txc =>
-      concat(
+    mergeMap(txc =>
+      concatWith(
         txc
           .run(
             'MERGE (bob:Person {name: $nameParam}) RETURN bob.name AS name',
@@ -397,7 +397,7 @@ rxSession
         of('Second query completed'),
         txc.commit(),
         of('committed')
-      ).pipe(catchError(err => txc.rollback().pipe(throwError(err))))
+      ).pipe(catchError(err => txc.rollback().pipe(throwError(() => err))))
     )
   )
   .subscribe({
 
@@ -222,7 +222,7 @@ rxSession
   .records()
   .pipe(
     map(record => record.get('name')),
-    concat(rxSession.close())
+    concatWith(rxSession.close())
   )
   .subscribe({
     next: data => console.log(data),
@@ -373,8 +373,8 @@ try {
 rxSession
   .beginTransaction()
   .pipe(
-    flatMap(txc =>
-      concat(
+    mergeMap(txc =>
+      concatWith(
         txc
           .run(
             'MERGE (bob:Person {name: $nameParam}) RETURN bob.name AS name',
@@ -397,7 +397,7 @@ rxSession
         of('Second query completed'),
         txc.commit(),
         of('committed')
-      ).pipe(catchError(err => txc.rollback().pipe(throwError(err))))
+      ).pipe(catchError(err => txc.rollback().pipe(throwError(() => err))))
     )
   )
   .subscribe({
 
@@ -87,6 +87,6 @@
     "@babel/runtime": "^7.17.8",
     "neo4j-driver-bolt-connection": "5.0.0-dev",
     "neo4j-driver-core": "5.0.0-dev",
-    "rxjs": "^6.6.7"
+    "rxjs": "^7.5.5"
   }
 }
@@ -20,7 +20,7 @@
 import { newError, error, internal, isRetriableError } from 'neo4j-driver-core'
 // eslint-disable-next-line no-unused-vars
 import { Observable, throwError, of } from 'rxjs'
-import { retryWhen, flatMap, delay } from 'rxjs/operators'
+import { retryWhen, mergeMap, delay } from 'rxjs/operators'
 
 const {
   logger: {
@@ -80,9 +80,9 @@ export default class RxRetryLogic {
         let delayDuration = this._initialDelay
 
         return failedWork.pipe(
-          flatMap(err => {
+          mergeMap(err => {
             if (!isRetriableError(err)) {
-              return throwError(err)
+              return throwError(() => err)
             }
 
             handledExceptions.push(err)
@@ -98,7 +98,7 @@ export default class RxRetryLogic {
 
               error.seenErrors = handledExceptions
 
-              return throwError(error)
+              return throwError(() => error)
             }
 
             const nextDelayDuration = this._computeNextDelay(delayDuration)
 
@@ -19,7 +19,7 @@
 /* eslint-disable-next-line no-unused-vars */
 import { newError, Record, ResultSummary } from 'neo4j-driver-core'
 import { Observable, Subject, ReplaySubject, from } from 'rxjs'
-import { flatMap, publishReplay, refCount } from 'rxjs/operators'
+import { mergeMap, publishReplay, refCount } from 'rxjs/operators'
 
 const States = {
   READY: 0,
@@ -41,7 +41,7 @@ export default class RxResult {
 
     this._result = replayedResult
     this._keys = replayedResult.pipe(
-      flatMap(r => from(r.keys())),
+      mergeMap(r => from(r.keys())),
       publishReplay(1),
       refCount()
     )
@@ -75,7 +75,7 @@ export default class RxResult {
    */
   records () {
     const result = this._result.pipe(
-      flatMap(
+      mergeMap(
         result =>
           new Observable(recordsObserver =>
             this._startStreaming({ result, recordsObserver })
@@ -97,7 +97,7 @@ export default class RxResult {
    */
   consume () {
     return this._result.pipe(
-      flatMap(
+      mergeMap(
         result =>
           new Observable(summaryObserver =>
             this._startStreaming({ result, summaryObserver })
 
@@ -17,7 +17,7 @@
  * limitations under the License.
  */
 import { defer, Observable, throwError } from 'rxjs'
-import { flatMap, catchError, concat } from 'rxjs/operators'
+import { mergeMap, catchError, concatWith } from 'rxjs/operators'
 import RxResult from './result-rx'
 // eslint-disable-next-line no-unused-vars
 import { Session, internal } from 'neo4j-driver-core'
@@ -230,16 +230,16 @@ export default class RxSession {
 
     return this._retryLogic.retry(
       this._beginTransaction(accessMode, txConfig).pipe(
-        flatMap(txc =>
+        mergeMap(txc =>
           defer(() => {
             try {
               return work(transactionWrapper(txc))
             } catch (err) {
-              return throwError(err)
+              return throwError(() => err)
             }
           }).pipe(
-            catchError(err => txc.rollback().pipe(concat(throwError(err)))),
-            concat(txc.commit())
+            catchError(err => txc.rollback().pipe(concatWith(throwError(() => err)))),
+            concatWith(txc.commit())
           )
         )
       )
 
@@ -245,7 +245,8 @@ describe('#unit-rx retrylogic', () => {
         clock.tick(delayBy)
       }
       if (index < errors.length) {
-        return throwError(errors[index++])
+        const i = index++
+        return throwError(() => errors[i])
       } else {
         return of(value)
       }
 
@@ -19,13 +19,13 @@
 
 import { Notification, throwError } from 'rxjs'
 import {
-  flatMap,
+  mergeMap,
   materialize,
   toArray,
-  concat,
   map,
   bufferCount,
-  catchError
+  catchError,
+  concatWith
 } from 'rxjs/operators'
 import neo4j from '../../src'
 // eslint-disable-next-line no-unused-vars
@@ -65,23 +65,23 @@ describe('#integration-rx transaction', () => {
     const messages = await session
       .beginTransaction()
       .pipe(
-        flatMap(txc =>
+        mergeMap(txc =>
           txc
             .run('UNWIND RANGE(1, $size) AS x RETURN x', { size })
             .records()
             .pipe(
               map(r => r.get(0)),
               bufferCount(50),
-              flatMap(x =>
+              mergeMap(x =>
                 txc
                   .run('UNWIND $x AS id CREATE (n:Node {id: id}) RETURN n.id', {
                     x
                   })
                   .records()
               ),
               map(r => r.get(0)),
-              concat(txc.commit()),
-              catchError(err => txc.rollback().pipe(concat(throwError(err)))),
+              concatWith(txc.commit()),
+              catchError(err => txc.rollback().pipe(concatWith(throwError(() => err)))),
               materialize(),
               toArray()
             )
@@ -105,7 +105,7 @@ describe('#integration-rx transaction', () => {
       .pipe(
         map(r => r.get(0)),
         bufferCount(50),
-        flatMap(x =>
+        mergeMap(x =>
           session
             .run('UNWIND $x AS id CREATE (n:Node {id: id}) RETURN n.id', {
               x
 
@@ -18,7 +18,7 @@
  */
 
 import { Notification, throwError } from 'rxjs'
-import { map, materialize, toArray, concat } from 'rxjs/operators'
+import { map, materialize, toArray, concatWith } from 'rxjs/operators'
 import neo4j from '../../src'
 import RxSession from '../../src/session-rx'
 import sharedNeo4j from '../internal/shared-neo4j'
@@ -377,7 +377,7 @@ describe('#integration rx-session', () => {
       .records()
       .pipe(
         map(r => r.get(0).toInt()),
-        concat(session.close())
+        concatWith(session.close())
       )
       .toPromise()
   }
@@ -403,7 +403,8 @@ describe('#integration rx-session', () => {
       }
 
       if (this._reactiveFailuresIndex < this._reactiveFailures.length) {
-        return throwError(this._reactiveFailures[this._reactiveFailuresIndex++])
+        const i = this._reactiveFailuresIndex++
+        return throwError(() => this._reactiveFailures[i])
       }
 
       return txc
Original file line number	Diff line number	Diff line change
`@@ -87,6 +87,6 @@`
`87`	`87`	`"@babel/runtime": "^7.17.8",`
`88`	`88`	`"neo4j-driver-bolt-connection": "5.0.0-dev",`
`89`	`89`	`"neo4j-driver-core": "5.0.0-dev",`
`90`		`- "rxjs": "^6.6.7"`
	`90`	`+ "rxjs": "^7.5.5"`
`91`	`91`	`}`
`92`	`92`	`}`
Original file line number	Diff line number	Diff line change
`@@ -245,7 +245,8 @@ describe('#unit-rx retrylogic', () => {`
`245`	`245`	`clock.tick(delayBy)`
`246`	`246`	`}`
`247`	`247`	`if (index < errors.length) {`
`248`		`- return throwError(errors[index++])`
	`248`	`+ const i = index++`
	`249`	`+ return throwError(() => errors[i])`
`249`	`250`	`} else {`
`250`	`251`	`return of(value)`
`251`	`252`	`}`
Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@`
`18`	`18`	`*/`
`19`	`19`
`20`	`20`	`import { Notification, throwError } from 'rxjs'`
`21`		`-import { map, materialize, toArray, concat } from 'rxjs/operators'`
	`21`	`+import { map, materialize, toArray, concatWith } from 'rxjs/operators'`
`22`	`22`	`import neo4j from '../../src'`
`23`	`23`	`import RxSession from '../../src/session-rx'`
`24`	`24`	`import sharedNeo4j from '../internal/shared-neo4j'`
`@@ -377,7 +377,7 @@ describe('#integration rx-session', () => {`
`377`	`377`	`.records()`
`378`	`378`	`.pipe(`
`379`	`379`	`map(r => r.get(0).toInt()),`
`380`		`- concat(session.close())`
	`380`	`+ concatWith(session.close())`
`381`	`381`	`)`
`382`	`382`	`.toPromise()`
`383`	`383`	`}`
`@@ -403,7 +403,8 @@ describe('#integration rx-session', () => {`
`403`	`403`	`}`
`404`	`404`
`405`	`405`	`if (this._reactiveFailuresIndex < this._reactiveFailures.length) {`
`406`		`- return throwError(this._reactiveFailures[this._reactiveFailuresIndex++])`
	`406`	`+ const i = this._reactiveFailuresIndex++`
	`407`	`+ return throwError(() => this._reactiveFailures[i])`
`407`	`408`	`}`
`408`	`409`
`409`	`410`	`return txc`