Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: multicast playground #111

Open
wants to merge 12 commits into
base: master
Choose a base branch
from
Open

feat: multicast playground #111

Changes from 1 commit
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
ea5877b
--wip--
May 24, 2017
bc5bcc3
fix: cleanup from auto java -> kotlin conversion
May 25, 2017
c36b9ad
feat: add using operator example [kotlin]
May 25, 2017
f42c9a8
feat: link it to a button
May 25, 2017
546bd2d
ref: move to kotlin folder + RxExt
May 26, 2017
8bb75eb
fix: clean up kotlin code
Jul 2, 2017
332a3cf
Merge branch 'kg/feat/using' of github.com:kaushikgopal/RxJava-Androi…
Jul 2, 2017
27a5758
chore: update agp + cradle
Jul 2, 2017
da11949
chore: make app multi-dex
Jul 2, 2017
67b860c
feat: add multicast playground example
Jul 2, 2017
a53b975
feat: cleanup and add README notes
Jul 17, 2017
25644fc
fix: add README link
Jul 17, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix: clean up kotlin code
  • Loading branch information
Kaushik Gopal committed Jul 2, 2017
commit 8bb75ebacab17c0f76839724aad4b358bc711b8c
23 changes: 10 additions & 13 deletions app/src/main/java/com/morihacky/android/rxjava/fragments/UsingFragment.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ import android.widget.ListView
import android.widget.TextView
import com.morihacky.android.rxjava.R
import io.reactivex.Flowable
import io.reactivex.disposables.Disposable
import io.reactivex.functions.Consumer
import io.reactivex.functions.Function
import org.reactivestreams.Publisher
Expand All @@ -22,10 +21,9 @@ import java.util.concurrent.Callable

class UsingFragment : BaseFragment() {

private var _logs: MutableList<String> = ArrayList()
private var _logsList: ListView? = null
private var _adapter: UsingFragment.LogAdapter? = null
private var disposable: Disposable? = null
private lateinit var _logs: MutableList<String>
private lateinit var _logsList: ListView
private lateinit var _adapter: UsingFragment.LogAdapter

override fun onCreateView(inflater: LayoutInflater?, container: ViewGroup?, savedInstanceState: Bundle?): View? {
val view = inflater?.inflate(R.layout.fragment_buffer, container, false)
Expand All @@ -52,11 +50,10 @@ class UsingFragment : BaseFragment() {
realm.clear()
}

disposable =
Flowable.using(resourceSupplier, sourceSupplier, disposer)
.subscribe({ i ->
_log("got a value $i - (look at the logs)")
})
Flowable.using(resourceSupplier, sourceSupplier, disposer)
.subscribe({ i ->
_log("got a value $i - (look at the logs)")
})
}

inner class Realm {
Expand All @@ -82,15 +79,15 @@ class UsingFragment : BaseFragment() {

// You can only do below stuff on main thread.
Handler(Looper.getMainLooper()).post {
_adapter!!.clear()
_adapter!!.addAll(_logs)
_adapter.clear()
_adapter.addAll(_logs)
}
}

private fun _setupLogger() {
_logs = ArrayList<String>()
_adapter = LogAdapter(activity, ArrayList<String>())
_logsList?.adapter = _adapter
_logsList.adapter = _adapter
}

private class LogAdapter(context: Context, logs: List<String>) : ArrayAdapter<String>(context, R.layout.item_log, R.id.item_log, logs)
Expand Down