Skip to content

Commit cf88034

Browse files
committed
Moving transaction to core
1 parent 686073e commit cf88034

File tree

3 files changed

+574
-1
lines changed

3 files changed

+574
-1
lines changed

core/src/internal/observers.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,3 +104,5 @@ export interface ResultStreamObserver extends StreamObserver {
104104
*/
105105
subscribe(observer: ResultObserver): void
106106
}
107+
108+
// @todo implement observers

core/src/result.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -297,7 +297,7 @@ class Result implements Promise<QueryResult> {
297297
* @protected
298298
* @since 4.0.0
299299
*/
300-
private _cancel(): void {
300+
_cancel(): void {
301301
this._streamObserverPromise.then(o => o.cancel())
302302
}
303303
}

0 commit comments

Comments
 (0)