jonathanrz jonathanrz

jonathanrz / DataSource.kt

Created November 6, 2017 23:35

	interface DataSource {
	fun all(): Observable<List<Data>>
	fun save(data: Data): Boolean
	}

	class DataRepository(private val dao: DataDao) : DataSource {
	private val generateData: () -> List<Data> = {
	dao.all()
	}
	private val mergeData: (List<Data>, Data) -> List<Data> = { cache, newData ->

jonathanrz / DatabaseObservable.kt

Created November 6, 2017 23:25

	class DatabaseObservable<T>(private val generateData: () -> List<T>, private val mergeData: (cache: List<T>, data: T) -> List<T>) {
	private var bs: BehaviorSubject<List<T>>? = null

	fun cache(): Observable<List<T>> {
	if(bs == null) {
	bs = BehaviorSubject.create()
	AsyncTask.execute { bs?.onNext(generateData()) }
	}
	return bs!!.replay(1).autoConnect()
	}

jonathanrz / DataSource.kt

Created November 6, 2017 23:20

	interface DataSource {
	fun all(): List<Data>
	fun save(data: Data): Boolean
	}

	class DataRepository(val dao: DataDao) : DataSource {
	override fun all(): List<Data> = dao.all()
	override fun save(data: Data): Boolean = dao.save(data) != 0L
	}

jonathanrz / datadao.kt

Created November 6, 2017 23:19

	@Dao
	interface DataDao {
	@Query("SELECT * FROM Data")
	fun all(): List<Data>

	@Insert(onConflict = OnConflictStrategy.REPLACE)
	fun save(data: Data): Long
	}

jonathanrz / data.kt

Created November 6, 2017 23:18

	@Entity
	data class Data(@PrimaryKey(autoGenerate = true) var id: Long = 0, var name: String = "")

jonathanrz / BehaviorSubjectOutput.kt

Created November 6, 2017 23:13

jonathanrz / BehaviorSubject.kt

Created November 6, 2017 23:12

	import io.reactivex.Observable;
	import io.reactivex.subjects.BehaviorSubject;

	public class Q47000608 {
	public static void main(String[] args) {
	BehaviorSubject<Integer> bs = BehaviorSubject.createDefault(1);
	Observable<Integer> o = bs.replay(1).autoConnect().distinctUntilChanged();
	o.subscribe(i -> System.out.println("s1 accept " + i));
	bs.onNext(2);
	o.subscribe(i -> System.out.println("s2 accept " + i));

jonathanrz / espresso_with_tag_en.java

Created July 10, 2017 18:47

	onView(allOf(
	withId(R.id.name),
	isDescendantOfA(withTagValue(is((Object)1L))))
	).check(matches(withText("Name")));

jonathanrz / simple_espresso_validation_en.java

Created July 10, 2017 18:44

onView(withId(R.id.name)).check(matches(withText("Name")));

jonathanrz / espresso_all_of.java

Created July 5, 2017 00:27

onView(allOf(matcher1, allOf(matcher2, matcher3))).check(assertion);