File tree Expand file tree Collapse file tree 2 files changed +38
-38
lines changed Expand file tree Collapse file tree 2 files changed +38
-38
lines changed Original file line number Diff line number Diff line change @@ -436,20 +436,20 @@ session
436436 return tx .run (' MERGE (alice:Person {name : $nameParam}) RETURN alice.name AS name' , {
437437 nameParam: ' Alice'
438438 })
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+ })
453453 })
454454```
455455
@@ -481,16 +481,16 @@ driver
481481
482482``` javascript
483483rxSession
484- .executeRead (txc =>
484+ .executeWrite (txc =>
485485 txc
486486 .run (' MERGE (james:Person {name: $nameParam}) RETURN james.name AS name' , {
487487 nameParam: ' Bob'
488- })
489- )
490- . records ( )
488+ })
489+ . records ( )
490+ )
491491 .pipe (
492492 map (record => record .get (' name' )),
493- concatWith (rxSession .close ())
493+ concatWith (session .close ())
494494 )
495495 .subscribe ({
496496 next : data => console .log (data),
Original file line number Diff line number Diff line change @@ -436,20 +436,20 @@ session
436436 return tx .run (' MERGE (alice:Person {name : $nameParam}) RETURN alice.name AS name' , {
437437 nameParam: ' Alice'
438438 })
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+ })
453453 })
454454```
455455
@@ -481,16 +481,16 @@ driver
481481
482482``` javascript
483483rxSession
484- .executeRead (txc =>
484+ .executeWrite (txc =>
485485 txc
486486 .run (' MERGE (james:Person {name: $nameParam}) RETURN james.name AS name' , {
487487 nameParam: ' Bob'
488- })
489- )
490- . records ( )
488+ })
489+ . records ( )
490+ )
491491 .pipe (
492492 map (record => record .get (' name' )),
493- concatWith (rxSession .close ())
493+ concatWith (session .close ())
494494 )
495495 .subscribe ({
496496 next : data => console .log (data),
You can’t perform that action at this time.
0 commit comments