Create a gist now

Instantly share code, notes, and snippets.

Blog post snippet
Observable<Object> tapEventEmitter = _rxBus.toObserverable().share();
Observable<Object> debouncedEventEmitter = tapEventEmitter.debounce(1, TimeUnit.SECONDS);
tapEventEmitter.buffer(debouncedEventEmitter)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment