Wie würden Sie RxJava verwenden, um Kontakte abzurufen?

Question

Wenn ich einen einzigen Kontakt wie so Abrufen:

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); 

     } 
    } 
} 

Wie würde ich es tun mit RxJava? Würde RxJava das irgendwie verbessern?

Answer 1

Ja, Sie können dies tun, verwenden Sie PublishSubject dafür.

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

Wenn Sie einen anderen Kontakt haben, rufen Sie contactPipe.onNext (newContact); Zugriff auf Quelle von Kontakten contactPipe.asObservable.subscribeOn(Schedulers.computation);

Ein weiteres Problem in Ihrem Code verwenden - langen Betrieb mit db auf Hauptthread. Um das zu lösen, verwenden Sie

Observable.defer(()-> Observable.just(contactUri)) 
.subscribeOn(Schedulers.io()) 
.map(t -> { 
    Contact c = getContactFromDb(contactUri); 
    return c; 
} 
// you can hand new contact directly, because PublishSubject implement Subscriber 
.subscribe(contactPipe);