returnObservable(): Observable<any> {
  return new Observable(observer => {
    if (/* whatever */) {
      return observer.next(body.data);
    } else {
      return observer.error(body.data);
    }

    return { unsubscribe() {} };
  });
}