KRAhn
diff --git a/Collapse file
‎app/src/main/java/com/morihacky/android/rxjava/SubjectDebounceSearchEmitterFragment.java‎
Copy file name to clipboardExpand all lines: app/src/main/java/com/morihacky/android/rxjava/SubjectDebounceSearchEmitterFragment.java
+13-15Lines changed: 13 additions & 15 deletions b/Collapse file
‎app/src/main/java/com/morihacky/android/rxjava/SubjectDebounceSearchEmitterFragment.java‎
Copy file name to clipboardExpand all lines: app/src/main/java/com/morihacky/android/rxjava/SubjectDebounceSearchEmitterFragment.java
+13-15Lines changed: 13 additions & 15 deletions
@@ -56,21 +56,6 @@ public class SubjectDebounceSearchEmitterFragment
   private Subscription _subscription;
   private PublishSubject<Observable<String>> _searchTextEmitterSubject;
 
-  @Override
-  public void onActivityCreated(@Nullable Bundle savedInstanceState) {
-    super.onActivityCreated(savedInstanceState);
-    _setupLogger();
-
-    _searchTextEmitterSubject = PublishSubject.create();
-    _subscription = AndroidObservable.bindFragment(SubjectDebounceSearchEmitterFragment.this,
-                                                   Observable.switchOnNext(_searchTextEmitterSubject))
-        // .debounce(400, TimeUnit.MILLISECONDS, Schedulers.io())
-        .throttleFirst(400, TimeUnit.MILLISECONDS, Schedulers.io())
-        .timeout(400, TimeUnit.MILLISECONDS, Schedulers.io())
-        .observeOn(AndroidSchedulers.mainThread())
-        .subscribe(_getSearchObserver());
-  }
-
   @OnTextChanged(R.id.input_txt_subject_debounce)
   public void onTextEntered(CharSequence charsEntered) {
     Timber.d("---------- text entered %s", charsEntered);
@@ -94,6 +79,19 @@ public View onCreateView(LayoutInflater inflater,
     return layout;
   }
 
+  @Override
+  public void onActivityCreated(@Nullable Bundle savedInstanceState) {
+    super.onActivityCreated(savedInstanceState);
+    _setupLogger();
+
+    _searchTextEmitterSubject = PublishSubject.create();
+    _subscription = AndroidObservable.bindFragment(SubjectDebounceSearchEmitterFragment.this,
+                                                   Observable.switchOnNext(_searchTextEmitterSubject))
+        .debounce(400, TimeUnit.MILLISECONDS, Schedulers.io())
+        .observeOn(AndroidSchedulers.mainThread())
+        .subscribe(_getSearchObserver());
+  }
+
   // -----------------------------------------------------------------------------------
   // Main Rx entities