rxDart 没有调用 onError

Question

我正在尝试使用 rxDart 向后端发出一个简单的请求。但是我面临的问题是，当我收到404之类的http错误时，不会调用onError，但是可以在onData中提取它。

我对 RxJava + 改造有一点经验，它按预期工作，当有错误响应时调用 http 状态代码 onError 并可以适当处理。

1.我做错了什么，还是故意的行为？

  Object sendProfileData() {
    Stream<Response> stream = onboardingRepository.createUser(User(name: 'name', surname: 'surname', lat: 1.0, lng: 2.0));
    stream.listen((response) {
      print(response.statusCode);
      setAttributes();
    }, onError: (e) {
      print(e);
    });
  }

OnboardingRepository.dart:

class OnboardingRepository {
  Observable<Response> createUser(User user) {
    return Observable.fromFuture(TMApi.createUser(user));
  }
}

TMApi.dart:

class TMApi {
  static Future<http.Response> createUser(User user) async {
    String url = '$baseUrl/create_user';
    return await http.post(url, body: json.encode(user.toJson()));
  }
}

在视图中处理事件的最佳方式是什么？如果发生错误，应该显示错误，否则应该打开一个新屏幕。 sendProfileData() 方法将 return 一个对象，基于此我将在视图中执行操作，但这听起来不是一个非常优雅的解决方案...
欢迎就架构提出任何建议:)

Answer 1

dart 中的 http 库与 Retrofit 有点不同。

http.post返回的Future只在io错误（socket错误，无网络）时抛出异常。

404 等服务器响应反映在 http.Response 中。

我创建了一个可能对您有所帮助的简单便捷方法：

void throwIfNoSuccess(http.Response response) {
  if(response.statusCode < 200 || response.statusCode > 299) {
    print('http error!');
    print(response.body);
    throw new HttpException(response);
  }
}

class HttpException implements Exception {
  HttpException(this.response);

  http.Response response;
}

使用方法：

import 'dart:convert';
import 'package:http/http.dart' as http;

Future<UserProfile> getUserProfile(String userId) async {
  final url = 'https://example.com/api/users/$userId';

  final response = await http.get(url);

  throwIfNoSuccess(response);

  final jsonBody = json.decode(response.body);

  return UserProfile.fromJson(jsonBody);
}

rxDart 没有调用 onError

rxDart not calling onError

stream

flutter

rxdart