example.kt

fun loadPosts() {
    retrofitService.getPosts()
        .filter { post -> post.author == me }
        .map { post -> createViewablePost(post) }
        .onComplete { posts -> view.showData(posts) }
        .onError { e -> view.showError(e) }
}