why using flatMap?

...flatMap(payload => {
          return Observable.of(new CloseDbSocketSuccess())

instead of using flatMap why don't you just use map()?
.map(payload => new CloseDbSocketSuccess())