Counter.kt

package io.bitsound.apitestapp.utils

import io.reactivex.subjects.BehaviorSubject
import java.util.concurrent.atomic.AtomicInteger


class Counter {

    val value: AtomicInteger = AtomicInteger()
    val emitter: BehaviorSubject<Int> = BehaviorSubject.createDefault(value.toInt())

    fun reset(): Counter {
        value.set(0)
        emitter.onNext(0)
        return this
    }

    fun keep(): Unit {
        emitter.onNext(value.get())
    }

    fun increase(): Unit {
        val nextValue = value.incrementAndGet()
        emitter.onNext(nextValue)
    }
}