seyedjafariy · March 18, 2018 06:17
diff --git a/ObservableThrottleTimeExample.java b/ObservableThrottleTimeExample.java
 Observable.create(searchEvents)
                .throttle(10, TimeUnit.SECONDS)
                .subscribe(new Consumer<events>() {
                    @Override
                    public void accept(Events events) throws Exception {
                        
                    }
                });
	Observable.create(searchEvents)
	.throttle(10, TimeUnit.SECONDS)
	.subscribe(new Consumer<events>() {
	@Override
	public void accept(Events events) throws Exception {

	}
	});