rohmanhakim

[default]
access_key = asf
bucket_location = US
cloudfront_host = cloudfront.amazonaws.com
cloudfront_resource = /2010-07-15/distribution
default_mime_type = binary/octet-stream
delete_removed = False
dry_run = False
encoding = UTF-8
encrypt = False

rohmanhakim

var a0 = 1;
var a1 = 2;
var a2 = 3;

var b0 = 4;
var b1 = 5;
var b2 = 6;
  
var ranks = [
  [a0,b0],

rohmanhakim

var nkq = ['3','2','3'];
var arr = (['1','2','3']).map(function(num) {
  return parseInt(num);
});

var m = ['0','1','2'];

var n = parseInt(nkq[0]);
var k = parseInt(nkq[1]);
var q = parseInt(nkq[2]);

rohmanhakim

package com.rohmanhakim.androidreactivedemo;

import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.text.Editable;
import android.text.TextWatcher;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;

rohmanhakim

package com.rohmanhakim.androidreactivedemo;

import android.support.v4.view.ViewCompat;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import android.widget.Toast;

rohmanhakim

package com.rohmanhakim.androidreactivedemo;

import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.text.Editable;
import android.text.TextUtils;
import android.text.TextWatcher;
import android.util.Log;
import android.view.View;
import android.widget.Button;

rohmanhakim

package com.rohmanhakim.androidreactivedemo;

import java.util.List;

import retrofit2.http.GET;
import rx.Observable;

public interface SampleService {
    @GET("emails")
    Observable<List<String>> getEmails();

rohmanhakim

// Return true jika email user sudah terpakai
        Observable<Boolean> emailStream = RxTextView.textChanges(etEmail)
                .map(new Func1<CharSequence, String>() {
                    @Override
                    public String call(CharSequence charSequence) {
                        return charSequence.toString();
                    }
                })
                .filter(new Func1<String, Boolean>() {
                    @Override

rohmanhakim

// Ambil daftar email dari APi, kemudian cek apakah email user sudah dipakai
    public Observable<Boolean> checkIfEmailExistFromAPI(final String input){
        return service.getEmails()
                .flatMap(new Func1<List<String>, Observable<String>>() { // Mengubah stream of List<String> menjadi stream of String
                    @Override
                    public Observable<String> call(List<String> strings) {
                        return Observable.from(strings);
                    }
                }).contains(input); // Cek apakah email di emit oleh stream sebelumnya
    }

rohmanhakim

// Return true jika email user sudah terpakai
        Observable<Boolean> emailStream = RxTextView.textChanges(etEmail)
                .map(new Func1<CharSequence, String>() {
                    @Override
                    public String call(CharSequence charSequence) {
                        return charSequence.toString();
                    }
                })
                .filter(new Func1<String, Boolean>() {
                    @Override