Как использовать Observers с обратными вызовами сокетов? - PullRequest
Новая
       11

Как использовать Observers с обратными вызовами сокетов?

0 голосов
/ 31 марта 2019

Я разработчик Android, который заинтересован в тестировании новых технологий. Знаете, я хочу использовать компоненты архитектуры для улучшения своих проектов.

Я хочу перечислить статьи с сервера и показать их в программе recyclerView. Следует отметить, что я использовал WebSocket для связи с сервером.

Моя процедура выглядит следующим образом:

Сначала я вызвал метод loadArticles из класса viewModel: 

BlogViewModel = ViewModelProvders.of(this).get(BlogViewModel.class);
viewModel.loadArticles();

Ниже тела BlogViewModel: 

public class BlogViewModel extends ViewModel {

private BlogRepository repository;
private CompositeDisposable compositeDisposable = new CompositeDisposable();

public ObservableField<Boolean> isLoading = new ObservableField<>();
public MutableLiveData<List<Article>> articles = new MutableLiveData<>();


public BlogViewModel() {
    this.repository = new BlogRepository();
}

public void loadArticles() {
    isLoading.set(true);

    compositeDisposable.add(repository
            .getArticles()
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeWith(new DisposableObserver<List<Article>>() {
                @Override
                public void onNext(List<Article> data) {
                    articles.setValue(data);
                }

                @Override
                public void onError(Throwable e) {
                    // FIXME: 3/31/2019
                }

                @Override
                public void onComplete() {
                    isLoading.set(false);
                }
            }));
}

@Override
protected void onCleared() {
    super.onCleared();

    if (!compositeDisposable.isDisposed()) {
        compositeDisposable.dispose();
    }
  }
}

Кроме того, класс BlogRepository определяется следующим образом: 

public class BlogRepository {

private BlogRemoteDataSource remoteDataSource = BlogRemoteDataSource.getInstance();

public Observable<List<Article>> getArticles() {
    if (Util.isConnect()) {
        return remoteDataSource.getArticles();
    } else {
        return null;
    }
  }
}

И класс BlogRemoteDataSource определяется следующим образом: 

public class BlogRemoteDataSource {

private Application app = (Application) Application.getInstance();
private List<Article> articles;

public static BlogRemoteDataSource getInstance() {
    return new BlogRemoteDataSource();
}

public Observable<List<Article>> getArticles() {
    JSONObject objData = new JSONObject();
    try {
        objData.put("itemID", "");
    } catch (JSONException e) {
        e.printStackTrace();
    }

    app.getSocket().observe(app.getOwner(), socket -> socket.event(Api.EVENT_GET_ARTICLE)
            .data(objData)
            .setCallbacks(new SocketCallback() {
                @Override
                public void onSuccess(JSONObject data) {
                    try {
                        articles = Article.parse(data.getJSONArray(Constant.PARAM_BODY));
                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
                }

                @Override
                public void onError(int code, String message) {
                }
            }).send());

    return Observable.just(articles);
    }
}

Моя проблема - когда я возвращаю Observable.just (статьи) в качестве вывода. После выполнения этой строки метод onNext в классе запускается как BlogViewModel, но когда список статей берется с сервера и значение, метод onNext не запускается.

Подскажите пожалуйста, как подсказать ViewModel, данные готовы?

Заранее спасибо.

1 Ответ

0 голосов
/ 31 марта 2019

Привет, вы можете использовать наблюдающий форевер вместо наблюдения только потому, что наблюдающий форевер () не привязан к какому-либо LifecycleOwner.поэтому используйте его, как показано ниже:

Сначала удалите ваш класс BlogRepository и обновите BlogViewModel, как показано ниже: 

public class BlogViewModel extends ViewModel {

private CompositeDisposable compositeDisposable = new CompositeDisposable();
private BlogRemoteDataSource remoteDataSource = BlogRemoteDataSource.getInstance();
public ObservableField<Boolean> isLoading = new ObservableField<>();

public BlogViewModel() {
    this.repository = new BlogRepository();
}

public void loadArticles() {
    isLoading.set(true);
    remoteDataSource.getArticles();
}

@Override
protected void onCleared() {
    super.onCleared();
    if (!compositeDisposable.isDisposed()) {
        compositeDisposable.dispose();
    }
  }
}

Затем обновите BlogRemoteDataSource, как показано ниже: 

public class BlogRemoteDataSource {

private Application app = (Application) Application.getInstance();
public MutableLiveData<List<Article>> articles = new MutableLiveData<>();

public static BlogRemoteDataSource getInstance() {
    return new BlogRemoteDataSource();
}

public void getArticles() {
    JSONObject objData = new JSONObject();
    try {
        objData.put("itemID", "");
    } catch (JSONException e) {
        e.printStackTrace();
    }

    app.getSocket().observeForever(app.getOwner(), socket -> socket.event(Api.EVENT_GET_ARTICLE)
            .data(objData)
            .setCallbacks(new SocketCallback() {
                @Override
                public void onSuccess(JSONObject data) {
                    try {
                        List<Article> newArticeList = Article.parse(data.getJSONArray(Constant.PARAM_BODY));
                        articles.postValue(newArticeList);
                        articles.notifyObserver();
                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
                }

                @Override
                public void onError(int code, String message) {
                }
            }).send());
    }
}

Надеюсь, это поможет сейчас !!:)

...