package org.ntlab.developrx;

import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;

/**
 * Created by matsumoto_k on 2017/11/11.
 */
public class JavaMainActivity extends AppCompatActivity {
    JavaRxProcess rxProcess = new JavaRxProcess();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main_java);

        findViewById(R.id.flowable_btn).setOnClickListener(view -> rxProcess.flowableReactiveStreams());
        findViewById(R.id.observable_btn).setOnClickListener(view -> rxProcess.observable());
        findViewById(R.id.just_btn).setOnClickListener(view -> rxProcess.just());
        findViewById(R.id.fromarray_btn).setOnClickListener(view -> rxProcess.fromArray());
        findViewById(R.id.range_btn).setOnClickListener(view -> rxProcess.range());
        findViewById(R.id.interval_btn).setOnClickListener(view -> rxProcess.interval());
        findViewById(R.id.timer_btn).setOnClickListener(view -> rxProcess.timer());
        findViewById(R.id.error_btn).setOnClickListener(view -> rxProcess.error());
    }
}