Skip to content

Commit 646339f

Browse files
authored
Fix RxResult method mapping (#729)
The method consume was wrongly mapped as summary.
1 parent 85403c8 commit 646339f

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

test/types/result-rx.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ res.records().subscribe({
3535
error: error => console.log(`records error: ${error}`)
3636
})
3737

38-
res.summary().subscribe({
38+
res.consume().subscribe({
3939
next: value => console.log(`summary: ${value}`),
4040
complete: () => console.log('summary complete'),
4141
error: error => console.log(`summary error: ${error}`)

test/types/session-rx.test.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ const result1: RxResult = rxSession.run('RETURN 1')
109109
result1.keys().subscribe(keysObserver)
110110
result1.records().subscribe(recordsObserver)
111111
result1
112-
.summary()
112+
.consume()
113113
.pipe(
114114
concat(close1),
115115
catchError(err => close1.pipe(concat(throwError(err))))
@@ -120,7 +120,7 @@ const result2: RxResult = rxSession.run('RETURN $value', { value: '42' })
120120
result2.keys().subscribe(keysObserver)
121121
result2.records().subscribe(recordsObserver)
122122
result2
123-
.summary()
123+
.consume()
124124
.pipe(
125125
concat(close1),
126126
catchError(err => close1.pipe(concat(throwError(err))))
@@ -135,7 +135,7 @@ const result3: RxResult = rxSession.run(
135135
result3.keys().subscribe(keysObserver)
136136
result3.records().subscribe(recordsObserver)
137137
result3
138-
.summary()
138+
.consume()
139139
.pipe(
140140
concat(close1),
141141
catchError(err => close1.pipe(concat(throwError(err))))

test/types/transaction-rx.test.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,12 +54,12 @@ const tx: RxTransaction = dummy
5454
const result1: RxResult = tx.run('RETURN 1')
5555
result1.keys().subscribe(keysObserver)
5656
result1.records().subscribe(recordsObserver)
57-
result1.summary().subscribe(summaryObserver)
57+
result1.consume().subscribe(summaryObserver)
5858

5959
const result2: RxResult = tx.run('RETURN $value', { value: '42' })
6060
result2.keys().subscribe(keysObserver)
6161
result2.records().subscribe(recordsObserver)
62-
result2.summary().subscribe(summaryObserver)
62+
result2.consume().subscribe(summaryObserver)
6363

6464
tx.commit()
6565
.pipe(concat(of('committed')))

types/result-rx.d.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ declare interface RxResult {
2424

2525
records(): Observable<Record>
2626

27-
summary(): Observable<ResultSummary>
27+
consume(): Observable<ResultSummary>
2828
}
2929

3030
export default RxResult

0 commit comments

Comments
 (0)