// DB操作を伴うとかそういう系のイメージ const Observable = require("rxjs/Rx").Observable; const { map, finalize, catchError } = require("rxjs/operators"); function foo (val) { console.log("foo!"); return val; } // connection closeは常にしたいとか function teardown () { console.log("teardown!"); } // エラーが起きたときだけrollbackしたいだとか function whenError(err) { console.log("some process..."); throw err; } function wantToDo () { retu
