Skip to content

Instantly share code, notes, and snippets.

View Diolor's full-sized avatar

Dionysis Lorentzos Diolor

255 followers · 10 following
View GitHub Profile
@Diolor
Diolor / FilterButtonPresenterTest.java
Created March 18, 2017 02:02
FilterButtonPresenterTest
@RunWith(MockitoJUnitRunner.class)
class FilterButtonPresenterTest {
@Mock
AccountInteractor accountInteractor;
@Mock
StateView<FilterButtonState> view;
@InjectMocks
FilterButtonPresenter testee;
@Diolor
Diolor / FilterButtonActivity.java
Created March 18, 2017 02:36
FilterButtonActivity
class MyActivity extends Activity implements StateView<FilterButtonState> {
private Button button;
@Inject
FilterButtonPresenter presenter;
@Override
protected void onCreate(Bundle savedInstanceState) {
// set some content views
Component.activity(this).inject(this); // dagger 2 injection
@Diolor
Diolor / gist:34441cad174483594e94e47bcfda1a1e
Created May 11, 2018 13:51
// build.gradle
apply plugin: EmailPlugin
// build src file
open class EmailPlugin : Plugin<Project> {
override fun apply(project: Project) {
// DO stuff
}
}
@Diolor
Diolor / subject.kt
Last active December 30, 2018 17:49
Rx Puzzles
fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")
fun main(args: Array<String>) {
printCurrentThread("main thread name")
val subject = BehaviorSubject.create(Unit)
subject
.subscribeOn(Schedulers.computation())
.subscribe {
@Diolor
Diolor / advancedSubject.kt
Last active December 1, 2018 01:47
fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")
fun main(args: Array<String>) {
printCurrentThread("main thread name")
val subject = BehaviorSubject.create(Unit)
subject
.subscribeOn(Schedulers.computation())
.subscribe {
@Diolor
Diolor / merge.kt
Created December 1, 2018 01:49
fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")
fun main(args: Array<String>) {
printCurrentThread("main thread name")
Observable
.merge(
just(Unit).subscribeOn(Schedulers.computation()),
just(Unit).subscribeOn(Schedulers.io())
)
@Diolor
Diolor / advancedMerge.kt
Created December 1, 2018 01:55
fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")
fun main(args: Array<String>) {
printCurrentThread("main thread name")
val subject = BehaviorSubject.create(Unit)
Observable
.merge(
just(Unit),
@Diolor
Diolor / combineLatest.kt
Last active December 1, 2018 02:10
fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")
fun main(args: Array<String>) {
printCurrentThread("main thread name")
Observable
.combineLatest(
just(Unit).observeOn(io()),
just(Unit).observeOn(computation())
) { _, _ ->
@Diolor
Diolor / combineLatestAdvanced.kt
Created December 1, 2018 02:09
fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")
fun main(args: Array<String>) {
printCurrentThread("main thread name")
val subject = BehaviorSubject.create(Unit)
Observable
.combineLatest(
subject.subscribeOn(io()),
@Diolor
Diolor / replayRefCount.kt
Last active December 1, 2018 13:04
fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")
fun main(args: Array<String>) {
printCurrentThread("main thread name")
val connectable = just(Unit)
.replay().refCount()
connectable
.subscribeOn(computation())