Android Kotlin和RxJava示例
示例
第一个示例在Kotlin中重新实现，并使用RxJava进行更清晰的交互。
import android.view.LayoutInflater
import android.view.View
import android.view.ViewGroup
import android.support.v7.widget.RecyclerView
import rx.subjects.PublishSubject
public class SampleAdapter(private val items: Array<String>) : RecyclerView.Adapter<SampleAdapter.ViewHolder>() {
//从rx.subject更改为不同的主题以获得不同的行为
//例如，BehaviorSubject允许在订阅时接收上一个事件
//另一方面，PublishSubject仅在订阅后才发送事件，这对于点击是理想的
public val itemClickStream: PublishSubject<View> = PublishSubject.create()
override fun getItemCount(): Int {
return items.size
}
override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): ViewHolder? {
val v = LayoutInflater.from(parent.getContext()).inflate(R.layout.text_row_item, parent, false);
return ViewHolder(view)
}
override fun onBindViewHolder(holder: ViewHolder, position: Int) {
holder.bind(items[position])
}
public inner class ViewHolder(view: View) : RecyclerView.ViewHolder(view) {
private val textView: TextView by lazy { view.findViewById(R.id.textView) as TextView }
init {
view.setOnClickListener{ v -> itemClickStream.onNext(v) }
}
fun bind(text: String) {
textView.text= text
}
}
}用法很简单。使用RxJava工具可以在单独的线程上进行订阅。
val adapter = SampleAdapter(arrayOf("Hello", "World"))
adapter.itemClickStream.subscribe { v ->
if (v.id == R.id.textView) {
//做点什么
}
}