BufferOperatorActivity.kt

package com.coderefer.rxandroidexamples.intro.operators.transform

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

private const val TAG = "BufferOperator"
class BufferOperatorActivity : AppCompatActivity() {
    private lateinit var disposable: Disposable

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

        val observable =
                Observable.just(10, 20, 30, 40, 50, 60)
                        .buffer(3)

        disposable = observable.subscribe {
            Log.d(TAG, "onNext: ")
            for(s in  it) {
                Log.d(TAG, s.toString())
            }
        }

    }

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