Skip to content

Instantly share code, notes, and snippets.

some_view.setOnClickListener(object : View.OnClickListener {
override fun onClick(view: View) {
println("clicked!")
}
})
val parent = node.getParent() ?: return null
val name = node.getName() ?: throw IllegalArgumentException("...")
if (x is String){
println(x)
}
// can be replaced with
(x as? String)?.let { println(x) }
school?.students?.let { doSomething(it.get(“billy”)) }
val school : School = null
if (school != null && school.students != null){
doSomething(school.students.get(“billy”))
}
package rx.plugins;
public class RxJavaTestPlugins extends RxJavaPlugins {
RxJavaTestPlugins() {
super();
}
public static void resetPlugins(){
getInstance().reset();
}
public class TestApplication extends BaseApplication implements TestLifecycleApplication {
@Override
public void onCreate() {
setupRxSchedulers();
super.onCreate();
}
private void setupRxSchedulers() {
RxJavaTestPlugins.resetPlugins();
@Test
public void testUsingTestSchedulers() throws Exception {
TestScheduler scheduler = new TestScheduler();
TestSubscriber<Long> testSubscriber = new TestSubscriber<>();
Observable.interval(1, TimeUnit.SECONDS, scheduler).take(5).observeOn(scheduler).subscribeOn(scheduler).subscribe(testSubscriber);
testSubscriber.assertNoValues();
scheduler.advanceTimeBy(2, TimeUnit.SECONDS);
testSubscriber.assertReceivedOnNext(Arrays.asList(0L, 1L));
scheduler.advanceTimeBy(10, TimeUnit.SECONDS);
testSubscriber.assertCompleted();
@Test
public void testUsingTestSubscriber() throws Exception {
TestSubscriber<Integer> testSubscriber = new TestSubscriber<>();
Observable.just(1).subscribe(testSubscriber);
testSubscriber.assertNoErrors();
testSubscriber.assertReceivedOnNext(Arrays.asList(1));
}
List<T> myList = myObservable.toList().toBlocking().single()
assertThat(myList.isEmpty()).is(false)