RxJavaを使用して連絡先を取得するにはどうすればよいですか？

Question

そうように私は、単一の連絡先を検索していた場合：

private void pickContact() { 
     Intent pickContactIntent = new Intent(Intent.ACTION_PICK, Uri.parse("content://contacts")); 
     pickContactIntent.setType(Phone.CONTENT_TYPE); 
     startActivityForResult(pickContactIntent, PICK_CONTACT_REQUEST); 
    } 



@Override 
protected void onActivityResult(int requestCode, int resultCode, Intent data) { 
    if (requestCode == PICK_CONTACT_REQUEST) { 
     if (resultCode == RESULT_OK) { 
      Uri contactUri = data.getData(); 
      String[] projection = {Phone.NUMBER}; 
      Cursor cursor = getContentResolver() 
        .query(contactUri, projection, null, null, null); 
      cursor.moveToFirst(); 

      int column = cursor.getColumnIndex(Phone.NUMBER); 
      String number = cursor.getString(column); 

     } 
    } 
} 

がどのように私はRxJavaを使用してそれを行うだろうか？ RxJavaはこれをどのようにして改善しますか？

Answer 1

はい、そうすることができます。そのためにはPublishSubjectを使用してください。

PublishSubject<Contact> contactPipe = PublishSubject.create(); 

他の連絡先を取得したら、contactPipe.onNext（newContact）を呼び出します。 連絡先のソースにアクセスするにはcontactPipe.asObservable.subscribeOn(Schedulers.computation);

メインスレッドでdbを使用してコードを長時間実行すると、別の問題が発生する可能性があります。 これを解決するには、