Возможно ли, чтобы MediatorLiveData ожидала обновления двух ливатат? - PullRequest
Новая
       9

Возможно ли, чтобы MediatorLiveData ожидала обновления двух ливатат?

1 голос
/ 11 марта 2020

Как видно из названия. У меня есть два объекта liveata, которые получают некоторые данные из API. Я хочу подождать, пока две жилататы закончат извлекать данные, прежде чем выполнять какую-либо операцию над их значениями. Это то, что я имею до сих пор: 

public class MainActivity extends AppCompatActivity implements View.OnClickListener {
    private Button myButt;
    private MainViewModel mvw;
    private TextView myView;
    private MediatorLiveData data;


    @Override
    protected void onCreate(Bundle savedInstanceState) {
        mvw = new ViewModelProvider(this).get(MainViewModel.class);

        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        myButt = findViewById(R.id.button);
        myView = findViewById(R.id.textview);
        myButt.setOnClickListener(this);

        data =  new MediatorLiveData<>();
        data.addSource(mvw.getAllOrders(), new Observer<Orders>() {
            @Override
            public void onChanged(Orders orders) {
                data.setValue(orders);
            }
        });
        data.addSource(mvw.getAllOrderRows(), new Observer<OrderRows>() {
                    @Override
                    public void onChanged(OrderRows orderRows) {
                        data.setValue(orderRows);

                    }
        });
        data.observe(this, new Observer<Orders>() { 
                    @Override
                    public void onChanged(Orders order) {
                        myView.setText(mvw.extractDate(order)); 
                         //Here i want to manipulate order and orderrows
                        Log.i("livedata" , order.getOrders().toString());
                    }
                });

    }

    @Override
    public void onClick(View view) {
        switch(view.getId()){
            case R.id.button:
                Log.i("button","clicked");
                mvw.updateOrderData(); // calls for new values to be fetched
                mvw.updateOrderRowData();
        }
    }
}

Проблема в том, что мне кажется, что я могу слушать только одну из двух живых данных. Как я могу подождать, пока оба завершат sh, а затем поработать над ними обоими?

1 Ответ

0 голосов
/ 13 марта 2020

Вы можете написать класс MergedMediatorLiveData следующим образом: 

class MergedLiveData<T, K, S>(sourceA: LiveData<T>, sourceB: LiveData<K>, private val mergedCallback: (resultA: T?, resultB: K?) -> S) : MediatorLiveData<S>() {

      private var resultA: T? = null
      private var resultB: K? = null

      init {
        super.addSource(sourceA) {
          resultA = it
          value = mergedCallback(resultA, resultB)
        }
        super.addSource(sourceB) {
          resultB = it
          value = mergedCallback(resultA, resultB)
        }
      }
    }

Таким образом, вы будете использовать: 

     val sample = MergedLiveData(sourceA = mvw.getAllOrders(), sourceB = mvw.getAllOrderRows())
      { resultA: OrderRows?, resultB: Orders? ->
        // Todo manipulate order and orderRows 
      }
...