// Path: app/src/main/java/com/rxjava2/android/samples/utils/AppConstant.java
// public final class AppConstant {
// 
//     private AppConstant() {
//         // This class in not publicly instantiable.
//     }
// 
//     public static final String LINE_SEPARATOR = "\n";
// 
// }
// 
// Path: app/src/main/java/com/rxjava2/android/samples/utils/ObserverAdapter.java
// public abstract class ObserverAdapter<T> implements Observer<T> {
//     @Override
//     public void onSubscribe(Disposable d) {
// 
//     }
// 
//     @Override
//     public void onNext(T s) {
// 
//     }
// 
//     @Override
//     public void onError(Throwable e) {
// 
//     }
// 
//     @Override
//     public void onComplete() {
// 
//     }
// }


import android.util.Log;
import com.rxjava2.android.samples.utils.AppConstant;
import com.rxjava2.android.samples.utils.ObserverAdapter;
import java.util.concurrent.TimeUnit;
import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.functions.BiFunction;
package com.rxjava2.android.samples.ui.operators;





public class TakeUntilExampleActivity extends TakeOperatorBaseActivity {

    private static final String TAG = TakeWhileExampleActivity.class.getSimpleName();

// Path: app/src/main/java/com/rxjava2/android/samples/utils/AppConstant.java
// public final class AppConstant {
// 
//     private AppConstant() {
//         // This class in not publicly instantiable.
//     }
// 
//     public static final String LINE_SEPARATOR = "\n";
// 
// }
// 
// Path: app/src/main/java/com/rxjava2/android/samples/utils/ObserverAdapter.java
// public abstract class ObserverAdapter<T> implements Observer<T> {
//     @Override
//     public void onSubscribe(Disposable d) {
// 
//     }
// 
//     @Override
//     public void onNext(T s) {
// 
//     }
// 
//     @Override
//     public void onError(Throwable e) {
// 
//     }
// 
//     @Override
//     public void onComplete() {
// 
//     }
// }


// Path: app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeUntilExampleActivity.java
import android.util.Log;
import com.rxjava2.android.samples.utils.AppConstant;
import com.rxjava2.android.samples.utils.ObserverAdapter;
import java.util.concurrent.TimeUnit;
import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.functions.BiFunction;

package com.rxjava2.android.samples.ui.operators;





public class TakeUntilExampleActivity extends TakeOperatorBaseActivity {

    private static final String TAG = TakeWhileExampleActivity.class.getSimpleName();

    @Override