FromOperatorActivity.kt

package com.coderefer.rxandroidexamples.intro.operators.create

import android.support.v7.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.coderefer.rxandroidexamples.R
import io.reactivex.Observable
import io.reactivex.disposables.Disposable

private const val TAG = "FromOperatorActivity"

class FromOperatorActivity : AppCompatActivity() {

    private lateinit var mDisposable : Disposable

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_from_operator)

        val numList = arrayListOf(11,12,13,14,15)

        val numObservable = Observable.fromIterable(numList)

        mDisposable = numObservable.subscribe {
            Log.d(TAG, it.toString())
        }
    }

    override fun onDestroy() {
        mDisposable.dispose()
        super.onDestroy()
    }
}