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();
        });
    }
}