Final example

final.java

private final PublishSubject<Void> viewClickedSubject = PublishSubject.create();
private final CompositeSubscription startStopCompositeSubscription = new CompositeSubscription();

@Override
protected void onStart() {
	super.onStart();
	
	view.setOnClickListener(v-> viewClickedSubject.onNext(null));

	Subscription subscription = viewClickedSubject
			.throttleFirst(200, TimeUnit.MILLISECONDS)
			.switchMap(aVoid-> api.getAlert()
					.retryWhen(RetryWithNetwork.create(context))
					.retryWhen(RetryExponetialy.create())
			)
			.subscribe(
				this::makeAlertToast,
				throwable -> {
					throw new OnErrorFailedException(" Unsubscribed from View click events.", throwable);
				}
			);

	startStopCompositeSubscription.add(subscription);
}

@Override
protected void onStop() {
	super.onStop();
	startStopCompositeSubscription.clear();
}