Convenient extensions of state and action

[dmdevgo]

In many cases, the state is a simple consumer of storage or another state. In this case, it is convenient to have an extension function that takes a data source and subscribes to it. This saves us from boilerplate code and makes the code more declarative:

val items = stateOf(repositoryObservable)

A similar problem exists when describing an action. You must subscribe to it and correctly resubscribe when you receive an error. The following code describes an action chain:

val buttonClicks = action<Unit> {
    this.filter { }
        .doOnNext { } 
}

[Jeevuz]

@dmdevgo Now you check and merge ;)