comment_view_model_integration.kt

class CommentViewModel(val model: CommentFormModel) {
   fun viewStateStream(): Flowable<CommentFormViewState> { 
     // define the relays that will allow to complete unidirectional data flow
     val textChangedEventRelay = PublishRelay.create<TextChangedEvent>()
     val submitEventRelay = PublishRelay.create<SubmitCommentEvent>()
     
     return model
       .dataStream(
         // We pass the user action flowables to the CommentFormModel 
         textChangedEvents = textChangedEventRelay.toFlowable(Backpressure.LATEST),
         submitEventRelay = submitEventRelay.toFlowable(Backpressure.LATEST)
       )
       .map { data ->
         // creating view state
         createViewStata(
           data = data,
           onTextChanged = { event ->
             // Pass the event to the relay
             textChangedEventRelay.accept(event)
           },
           onSubmitSelected = { event ->
             // Pass the event to the relay                  
             submitEventRelay.accept(event)
           })
       }
   }
}