Diolor

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.Looper;

import rx.Observable;
import rx.Scheduler;

Diolor

class JobsListAdapter : ListAdapter<JobListItem, JobViewHolder>() {

    override fun getItemViewType(position: Int): Int {
        return getItem(position).ordinal()
    }

    override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): JobViewHolder {
        return when (viewType) {
            Header.ordinal() -> HeaderViewHolder(...)
            JobItem.ordinal() -> JobViewHolder(...)

Diolor

/**
 * ListAdapter is a superclass of RecyclerView.Adapter. 
 * Check the d.android.com for more.
 */
class JobsAdapter : ListAdapter<JobListItem, JobViewHolder>() {

}

// items of 2 types 
sealed class JobListItem {

Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val subject = BehaviorSubject.create(Unit)

	subject
			.subscribeOn(Schedulers.computation())
			.subscribe {

Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val connectable = just(Unit)
			.replay().refCount()

	connectable
			.subscribeOn(newThread())

Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val connectable = just(Unit)
			.replay().refCount()

	connectable
			.subscribeOn(computation())

Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val subject = BehaviorSubject.create(Unit)

	val connectable = subject
			.observeOn(io())
			.replay().refCount()

Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	Observable
			.combineLatest(
					just(Unit).observeOn(io()),
					just(Unit).observeOn(computation())
			) { _, _ ->

Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val subject = BehaviorSubject.create(Unit)

	Observable
			.combineLatest(
					subject.subscribeOn(io()),

Diolor

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val subject = BehaviorSubject.create(Unit)

	Observable
			.merge(
					just(Unit),