-
Notifications
You must be signed in to change notification settings - Fork 1
/
MainActivity.kt
82 lines (64 loc) · 2.57 KB
/
MainActivity.kt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package com.jacquessmuts.rxextensionsexample
import android.os.Bundle
import android.support.design.widget.Snackbar
import android.support.v7.app.AppCompatActivity
import android.view.Menu
import android.view.MenuItem
import com.jacquessmuts.rxextensions.LazyPublishSubject
import com.jacquessmuts.rxextensions.RxHelper
import com.jacquessmuts.rxextensions.computationThread
import com.jacquessmuts.rxextensions.filterRapidClicks
import com.jacquessmuts.rxextensions.subscribeAndLogE
import com.jacquessmuts.rxextensions.uiThread
import kotlinx.android.synthetic.main.activity_main.*
import timber.log.Timber
class MainActivity : AppCompatActivity() {
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
setSupportActionBar(toolbar)
fab.setOnClickListener { view ->
Snackbar.make(view, "Replace with your own action", Snackbar.LENGTH_LONG)
.setAction("Action", null).show()
}
setDefault()
setObservable()
}
override fun onCreateOptionsMenu(menu: Menu): Boolean {
// Inflate the menu; this adds items to the action bar if it is present.
menuInflater.inflate(R.menu.menu_main, menu)
return true
}
override fun onOptionsItemSelected(item: MenuItem): Boolean {
// Handle action bar item clicks here. The action bar will
// automatically handle clicks on the Home/Up button, so long
// as you specify a parent activity in AndroidManifest.xml.
return when (item.itemId) {
R.id.action_settings -> true
else -> super.onOptionsItemSelected(item)
}
}
val stringPublisher by LazyPublishSubject<String>()
fun setDefault() {
Timber.plant(Timber.DebugTree())
RxHelper.setDefaultErrorHandling { throwable ->
// Every time .subscribeAndLogE catches an error, this will run
Timber.e(throwable)
}
// events faster than 500ms will be filtered out by .filterRapidClick()
RxHelper.setMaximumClickRapidity(500)
}
fun setObservable() {
stringPublisher
.filterRapidClicks() // filters out rapid events within 300ms
.computationThread() // Puts this on computation thread
.uiThread() // Puts this back on ui/main thread
.map {
throw Exception("testttttt")
}
.subscribeAndLogE { string ->
//do something with string
}
stringPublisher.onNext("test")
}
}