在Android上使用反应式绑定处理多个按钮点击

implementation 'io.reactivex.rxjava2:rxjava:2.x.x'
implementation 'io.reactivex.rxjava2:rxandroid:2.x.x'

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.functions.Consumer;

public class MainActivity extends AppCompatActivity {
    private CompositeDisposable disposables = new CompositeDisposable();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Button button1 = findViewById(R.id.button1);
        Button button2 = findViewById(R.id.button2);

        Observable<Object> buttonClicks = Observable.create(emitter -> {
            button1.setOnClickListener(view -> emitter.onNext(view));
            button2.setOnClickListener(view -> emitter.onNext(view));
        });

        disposables.add(buttonClicks
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(this::handleButtonClick));
    }

    private void handleButtonClick(Object view) {
        // 处理按钮点击事件
        if (view instanceof Button) {
            Button button = (Button) view;
            String buttonText = button.getText().toString();
            Toast.makeText(this, "Button clicked: " + buttonText, Toast.LENGTH_SHORT).show();
        }
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        disposables.dispose();
    }
}