File tree 2 files changed +38
-38
lines changed
2 files changed +38
-38
lines changed Original file line number Diff line number Diff line change @@ -436,20 +436,20 @@ session
436
436
return tx .run (' MERGE (alice:Person {name : $nameParam}) RETURN alice.name AS name' , {
437
437
nameParam: ' Alice'
438
438
})
439
- })
440
- . subscribe ( {
441
- onKeys : keys => {
442
- console . log (keys)
443
- },
444
- onNext : record => {
445
- console . log ( record . get ( ' name ' ))
446
- },
447
- onCompleted : () => {
448
- session . close () // returns a Promise
449
- },
450
- onError : error => {
451
- console . log (error)
452
- }
439
+ . subscribe ({
440
+ onKeys : keys => {
441
+ console . log (keys)
442
+ },
443
+ onNext : record => {
444
+ console . log ( record . get ( ' name ' ))
445
+ },
446
+ onCompleted : () => {
447
+ session . close () // returns a Promise
448
+ },
449
+ onError : error => {
450
+ console . log (error)
451
+ }
452
+ })
453
453
})
454
454
```
455
455
@@ -481,16 +481,16 @@ driver
481
481
482
482
``` javascript
483
483
rxSession
484
- .executeRead (txc =>
484
+ .executeWrite (txc =>
485
485
txc
486
486
.run (' MERGE (james:Person {name: $nameParam}) RETURN james.name AS name' , {
487
487
nameParam: ' Bob'
488
- })
489
- )
490
- . records ( )
488
+ })
489
+ . records ( )
490
+ )
491
491
.pipe (
492
492
map (record => record .get (' name' )),
493
- concatWith (rxSession .close ())
493
+ concatWith (session .close ())
494
494
)
495
495
.subscribe ({
496
496
next : data => console .log (data),
Original file line number Diff line number Diff line change @@ -436,20 +436,20 @@ session
436
436
return tx .run (' MERGE (alice:Person {name : $nameParam}) RETURN alice.name AS name' , {
437
437
nameParam: ' Alice'
438
438
})
439
- })
440
- . subscribe ( {
441
- onKeys : keys => {
442
- console . log (keys)
443
- },
444
- onNext : record => {
445
- console . log ( record . get ( ' name ' ))
446
- },
447
- onCompleted : () => {
448
- session . close () // returns a Promise
449
- },
450
- onError : error => {
451
- console . log (error)
452
- }
439
+ . subscribe ({
440
+ onKeys : keys => {
441
+ console . log (keys)
442
+ },
443
+ onNext : record => {
444
+ console . log ( record . get ( ' name ' ))
445
+ },
446
+ onCompleted : () => {
447
+ session . close () // returns a Promise
448
+ },
449
+ onError : error => {
450
+ console . log (error)
451
+ }
452
+ })
453
453
})
454
454
```
455
455
@@ -481,16 +481,16 @@ driver
481
481
482
482
``` javascript
483
483
rxSession
484
- .executeRead (txc =>
484
+ .executeWrite (txc =>
485
485
txc
486
486
.run (' MERGE (james:Person {name: $nameParam}) RETURN james.name AS name' , {
487
487
nameParam: ' Bob'
488
- })
489
- )
490
- . records ( )
488
+ })
489
+ . records ( )
490
+ )
491
491
.pipe (
492
492
map (record => record .get (' name' )),
493
- concatWith (rxSession .close ())
493
+ concatWith (session .close ())
494
494
)
495
495
.subscribe ({
496
496
next : data => console .log (data),
You can’t perform that action at this time.
0 commit comments