Android Livedata Observer nicht aktiv nach dem ersten Update

Question

ich eine grundlegende Implementierung der Architektur Komponenten der Live-Daten mit Kotlin ausprobieren wie folgt aus:

class MarketFragment : LifecycleFragment(){ 
...... 
override fun onActivityCreated(savedInstanceState: Bundle?) { 
     super.onActivityCreated(savedInstanceState) 
     viewModel=ViewModelProviders.of(this).get(MarketViewModel::class.java) 
     viewModel.book?.observe(this, Observer { book-> //updateUI }) 
.... 

Meine Viewmodel-Klasse wird wie folgt erstellt:

class MarketViewModel : ViewModel() 
{ 
    var book: MutableLiveData<Book>? =MutableLiveData() 
    var repository: Repository?= Repository() 

    init { 
     update("parameter") 
    } 

    fun update(s: String) 
    { 
     book=repository?.getBook(s) 

    } 

} 

And My Repository:

fun getBook(bookSymbol:String):MutableLiveData<Book> 
{ 
    val book=MutableLiveData<Book>() 
    ...... 

      call . enqueue (object : Callback<Book> { 
     override fun onResponse(call: Call<Book>?, response: Response<Book>?) { 

      book.value=response?.body() 

     } 
    ..... 
    }) 
      return book 
} 

}

Und das alles funktioniert großartig und UI wird aktualisiert, wie es sollte, aber nur zum ersten Mal. Wenn ich versuche, manuell, Anrufe zu tätigen, das Ansichtsmodell von einer UI-Aktion zu aktualisieren, der Retrofit-Aufruf funktioniert immer noch wie erwartet, aber die neuen Daten nicht auf den Beobachter im Fragmente gesendet:

//this doesn't work: 
viewModel.update("string") 
//This returns false: 
viewModel.book.hasActiveObservers() 

Ist es das erwartete Verhalten für ein Observer nach dem ersten Trigger inaktiv werden?

Answer 1

Sie erstellen eine neue MutableLiveData Instanz jedes Mal, wenn Sie anrufen getBooks

Daher Ihr Beobachter LiveData das Recht nicht beobachtet mehr.

Um dieses Problem zu lösen, sollte Ihr ViewModel nur eine MutableLiveData-Instanz enthalten und Aktualisierungen mit der Funktion postValue an diese senden.

Das Repository kann dann RxJava (Flowable) verwenden, um die Abfrage auf einem Hintergrund-Thread ausgeführt werden und ein Observable<Book> (oder Single<Book>)