FirebaseTracker.kt

class FirebaseTracker @Inject constructor(
    private val context: Context,
    private val eventsStreamProvider: EventsStreamProvider,
    private val mapper: FirebaseMapper
) {

    private val compositeDisposable = CompositeDisposable()

    init {
        subscribeToEvents()
    }

    private fun subscribeToEvents() {
        compositeDisposable.add(
            eventsStreamProvider
                .eventStream
                .map{ mapper.mapFrom(it) }
                .subscribe({
                    sendEvent(it)
                }, {
                    logError(it.localizedMessage)
                })
        )
    }

    private fun logError(err: String) {
        // do something here, crashlytics or whatever
        Log.i("FirebaseTracker::error", err)
    }

    private fun sendEvent(e: FirebaseEvent) {
        FirebaseAnalytics.getInstance(context).logEvent(e.name, e.params)
    }
}