Ensure these errors make their way out to the caller instead of only
logging an error.
Signed-off-by: Bill Erickson <berickxx@gmail.com>
Signed-off-by: Galen Charlton <gmc@equinoxinitiative.org>
Signed-off-by: Jane Sandberg <sandbej@linnbenton.edu>
res => observer.next(res),
err => observer.error(err),
() => {
- this.xactClose().toPromise().then(() => {
- // 5. disconnect
- this.disconnect();
- // 6. all done
- observer.complete();
- });
+ this.xactClose().toPromise().then(
+ ok => {
+ // 5. disconnect
+ this.disconnect();
+ // 6. all done
+ observer.complete();
+ },
+ // xact close error
+ err => observer.error(err)
+ );
}
);
});