livestream-kt

alltypes

data class DataItem<T>

DataItem(value: T? = null, onChangeListener: MutableList<OnChangeListener<T>>? = null)
var onChangeListener: MutableList<OnChangeListener<T>>?
var value: T?

class DataStore<T : Any>

@JvmStatic @Synchronized fun <T : Any> getInstance(): DataStore<T>?
fun getValue(key: String): T?
fun removeListener(key: String, onChangeListener: OnChangeListener<T>?): Unit
fun setListener(key: String, listener: OnChangeListener<T>?): Unit
fun setValue(key: String, value: T?): Unit

class LiveStream<T : Any> : ILiveStream<T>

LiveStream()
fun getValue(stream: String): T?
interface OnChangeListener<T>

abstract fun onChange(value: T?): Unit

fun post(stream: String, value: T?): Unit
@MainThread fun set(stream: String, value: T?): Unit
fun subscribe(stream: String, onChangeListener: OnChangeListener<T>): StreamObserver<T>
fun unsubscribe(observer: StreamObserver<T>): Unit

class StreamObserver<T : Any>

val stream: String

package dev.shreyaspatil.livestream

class LiveStream<T : Any> : ILiveStream<T>

LiveStream()
fun getValue(stream: String): T?
interface OnChangeListener<T>

abstract fun onChange(value: T?): Unit

fun post(stream: String, value: T?): Unit
@MainThread fun set(stream: String, value: T?): Unit
fun subscribe(stream: String, onChangeListener: OnChangeListener<T>): StreamObserver<T>
fun unsubscribe(observer: StreamObserver<T>): Unit

class StreamObserver<T : Any>

val stream: String

package dev.shreyaspatil.livestream.data

data class DataItem<T>

DataItem(value: T? = null, onChangeListener: MutableList<OnChangeListener<T>>? = null)
var onChangeListener: MutableList<OnChangeListener<T>>?
var value: T?

class DataStore<T : Any>

@JvmStatic @Synchronized fun <T : Any> getInstance(): DataStore<T>?
fun getValue(key: String): T?
fun removeListener(key: String, onChangeListener: OnChangeListener<T>?): Unit
fun setListener(key: String, listener: OnChangeListener<T>?): Unit
fun setValue(key: String, value: T?): Unit

package dev.shreyaspatil.livestream.extension

fun <T : Any> LiveStream<T>.subscribe(stream: String, onChangeCallback: (T?) -> Unit): StreamObserver<T>