我正在尝试创建一个自定义
ImageButton,当用户停止单击按钮1秒钟时,它将累积点击并触发事件.
我用debounce函数来完成这个.
自定义ImageButton：
public class MBImageButton extends ImageButton {
private AtomicInteger mCounter;
private disposable mdisposable;
private Observable<Object> observable;
private OnAccumulatedRequestsRead mOnAccumulatedRequestsRead;
private OnEverClickListener mOnEverClickListener;
private int emitEveryMilli = 1000; // every 1 second by default
private boolean shoulddispoSEOnDetachFromWindow = true;
public MBImageButton(Context context) {
super(context);
init();
}
public MBImageButton(Context context,AttributeSet attrs) {
super(context,attrs);
init();
}
public MBImageButton(Context context,AttributeSet attrs,int defStyleAttr) {
super(context,attrs,defStyleAttr);
init();
}
public void setAccumulatedClickListeners(OnEverClickListener onEverClickListener,OnAccumulatedRequestsRead onAccumulatedRequestsRead) {
setonAccumulatedRequestsRead(onAccumulatedRequestsRead);
setonEverClickListener(onEverClickListener);
initClickObservable();
subscribe();
}
private void initClickObservable() {
observable = Observable.create(emitter -> {
emitter.setCancellable(() -> setonClickListener(null));
try {
setonClickListener(view -> {
try {
final int currentCount = mCounter.incrementAndGet();
Timber.d("Clicked: " + currentCount);
if (mOnEverClickListener != null) {
mOnEverClickListener.onEveryClickListener(currentCount);
}
emitter.onNext(new Object());
} catch (Exception e) {
emitter.onError(e);
}
});
} catch (Exception e) {
emitter.onError(e);
}
}).doOnSubscribe(disposable -> mdisposable = disposable)
.debounce(emitEveryMilli,TimeUnit.MILLISECONDS);
}
private void subscribe() {
observable.subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread())
.subscribe(o -> {
try {
final int count = mCounter.get();
if(count==0) return;
mCounter.set(0);
Timber.d("Accumulated Clicks: " + count);
if (mOnAccumulatedRequestsRead != null) {
mOnAccumulatedRequestsRead.onAccumulatedRequestsReady(count);
}
} catch (Exception e) {
Timber.e(e);
}
},Timber::e);
}
private void init() {
mCounter = new AtomicInteger(0);
}
public void disposeAccumulatedClickListeners() {
if (mdisposable != null) {
mdisposable.dispose();
}
}
public void shoulddispoSEOnDetachFromWindow(boolean shoulddispoSEOnDetachFromWindow) {
this.shoulddispoSEOnDetachFromWindow = shoulddispoSEOnDetachFromWindow;
}
public void setEmitEveryMilliseconds(int emitEveryMilli) {
this.emitEveryMilli = emitEveryMilli;
initClickObservable();
subscribe();
}
private void setonEverClickListener(OnEverClickListener onEverClickListener) {
mOnEverClickListener = onEverClickListener;
}
private void setonAccumulatedRequestsRead(OnAccumulatedRequestsRead onAccumulatedRequestsRead) {
mOnAccumulatedRequestsRead = onAccumulatedRequestsRead;
}
@Override
protected void onDetachedFromWindow() {
super.onDetachedFromWindow();
if (shoulddispoSEOnDetachFromWindow) {
if (mdisposable != null) {
mdisposable.dispose();
}
}
}
public interface OnAccumulatedRequestsRead {
void onAccumulatedRequestsReady(int count);
}
public interface OnEverClickListener {
void onEveryClickListener(int currentCount);
}
}
设置此imageButton进行去抖动的功能是：
setAccumulatedClickListeners(OnEverClickListener,OnAccumulatedRequestsRead)
当我从RecyclerView设置此视图时,一切正常,
当我按顺序点击9次时,结果如下所示：
D/MBImageButton: Clicked: 1 D/MBImageButton: Clicked: 2 D/MBImageButton: Clicked: 3 D/MBImageButton: Clicked: 4 D/MBImageButton: Clicked: 5 D/MBImageButton: Clicked: 6 D/MBImageButton: Clicked: 7 D/MBImageButton: Clicked: 8 D/MBImageButton: Clicked: 9 D/MBImageButton: Accumulated Clicks: 9
当我将此自定义ImageButton添加到RecyclerView ViewHolder时,对于相同的点击次数,结果不正确：
D/MBImageButton: Clicked: 1 D/MBImageButton: Clicked: 2 D/MBImageButton: Clicked: 1 D/MBImageButton: Clicked: 3 D/MBImageButton: Clicked: 2 D/MBImageButton: Clicked: 4 D/MBImageButton: Accumulated Clicks: 4 D/MBImageButton: Clicked: 1 D/MBImageButton: Accumulated Clicks: 2 D/MBImageButton: Clicked: 2 D/MBImageButton: Accumulated Clicks: 2 D/MBImageButton: Accumulated Clicks: 0 D/MBImageButton: Clicked: 1 D/MBImageButton: Accumulated Clicks: 1 D/MBImageButton: Accumulated Clicks: 0 D/MBImageButton: Accumulated Clicks: 0
这是另外9次连续点击的结果：
D/MBImageButton: Clicked: 1 D/MBImageButton: Clicked: 2 D/MBImageButton: Clicked: 1 D/MBImageButton: Clicked: 3 D/MBImageButton: Clicked: 2 D/MBImageButton: Clicked: 4 D/MBImageButton: Clicked: 3 D/MBImageButton: Accumulated Clicks: 4 D/MBImageButton: Clicked: 1 D/MBImageButton: Accumulated Clicks: 3 D/MBImageButton: Accumulated Clicks: 1 D/MBImageButton: Accumulated Clicks: 0 D/MBImageButton: Clicked: 1 D/MBImageButton: Accumulated Clicks: 1 D/MBImageButton: Accumulated Clicks: 0 D/MBImageButton: Accumulated Clicks: 0 D/MBImageButton: Accumulated Clicks: 0
在这两次我用相同的间隔时间点击,但当这个按钮添加到RecyclerView时,它给出了奇怪的结果.
可能是什么问题？
更新：
我的Adapter简化了实现：
public class ProductRVAdapter extends BaseProductRVAdapter<ProductRVAdapter.ProductVH> {
private ProductAdapterListener mProductAdapterListener;
public ProductRVAdapter(List<Product> productList,ProductAdapterListener productAdapterListener) {
super(productList);
mProductAdapterListener = productAdapterListener;
}
@Override
public ProductVH onCreateViewHolder(ViewGroup parent,int viewType) {
final View view = LayoutInflater.from(parent.getContext()).inflate(R.layout.item_product,parent,false);
return new ProductVH(view);
}
@Override
public void onBindViewHolder(ProductVH holder,int position) {
holder.bind(productList.get(position),position);
holder.ib_decrease.setAccumulatedClickListeners(currentCount -> onProductAdapterDecreaseClicked.onClick(holder.ib_decrease),count -> {
if (mProductAdapterListener != null) {
mProductAdapterListener.onProductAdapterProductChangetoWSListener(productList.get(position),position,-count);
}
});
holder.ib_add.setAccumulatedClickListeners(currentCount -> onProductAdapteraddToCartClicked.onClick(holder.ib_add),count);
}
});
}
public interface ProductAdapterListener {
void onProductAdapteraddToCartClicked(Product product,int position);
void onProductAdapterProductChangetoWSListener(Product product,int position,int amountChanged);
void onProductAdapterDecreaseClicked(Product product,int position);
}
public static class ProductVH extends RecyclerView.ViewHolder {
@BindView(R.id.iv_productimage)
ImageView iv_producImage;
@BindView(R.id.tv_productName)
TextView tv_productName;
@BindView(R.id.tv_prodamount)
MBTextView tv_prodamount;
@BindView(R.id.ib_decrease)
MBImageButton ib_decrease;
@BindView(R.id.ib_add)
MBImageButton ib_add;
ProductVH(View itemView) {
super(itemView);
ButterKnife.bind(this,itemView);
}
public void bind(Product product,int position) {
tv_productName.setText(product.getName());
tv_prodamount.setText(product.getAmount());
ImageLoader.loadImage(iv_producImage.getContext(),iv_producImage,product.getImg(),R.drawable.ic_category_item);
ib_decrease.setTag(position);
ib_add.setTag(position);
}
}
}
解决方法
我得到了解决方案
主要的问题是当我在RecyclerView适配器中滚动时,vies会从窗口中分离并调用onDetachedFromWindow函数,在该函数中我从observable取消订阅(dispose).
尝试的解决方案：
1.我添加了attachFunction
@Override
protected void onAttachedToWindow() {
super.onAttachedToWindow();
if (shoulddispoSEOnDetachFromWindow) {
if (mdisposable != null) {
if (mdisposable.isdisposed()) {
initClickObservable();
subscribe();
}
}
}
}
通常我使用notifyItemChange()进行一些修改后更新视图.现在我直接通过setText或类似函数更新视图.
它现在正常工作.
