jmarsican

package me.jorgecastillo.polymorphicapps.polymorphic

import arrow.Kind
import arrow.core.Option
import arrow.core.left
import arrow.core.right
import arrow.effects.IO
import arrow.effects.async
import arrow.effects.fix
import arrow.effects.typeclasses.Async

jmarsican

interface DataSource {
  fun allTasksByUser(user: User): Observable<List<Task>>
}

class LocalDataSource : DataSource {
  private val localCache: Map<User, List<Task>> =
    mapOf(User(UserId("user1")) to listOf(Task("LocalTask assigned to user1")))

  override fun allTasksByUser(user: User): Observable<List<Task>> = Observable.create { emitter ->
    val cachedUser = localCache[user]