Skip to content

Instantly share code, notes, and snippets.

@nglauber
Created November 13, 2017 13:07
Show Gist options
  • Save nglauber/8277344ed9d79cb5db26a6663231f7a5 to your computer and use it in GitHub Desktop.
Save nglauber/8277344ed9d79cb5db26a6663231f7a5 to your computer and use it in GitHub Desktop.
data class User(val name: String)
data class Message(val title: String, val sender: User?)
val list = listOf(
Message("Message 1", null),
Message("Message 2", null),
Message("Message 3", null)
)
Observable.merge(
mutableListOf(
Observable.fromIterable(list)
.flatMap { a -> Observable.just(a) },
Observable.just(User("Nelson"))
.map { user -> Message("Message com User 1", user) },
Observable.just(User("Glauber"))
.map { user -> Message("Message com User 2", user) },
Observable.just(User("Vasconcelos"))
.map { user -> Message("Message com User 3", user) },
Observable.just(User("Leal"))
.map { user -> Message("Message com User 4", user) }
)
).subscribe { message ->
print(message.toString())
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment