Я использую goswagger для генерации моего кода restAPI, и как часть этого сгенерированного кода для написания ответов я должен возвращать промежуточное ПО. Я хотел бы иметь возможность писать ответ напрямую с помощью клиента API, поскольку я использую реактивное расширение gorx, которое невозможно вернуть значение, поскольку оно работает в асинхронном режиме.
Code Example:
//Handle which is generated by goswagger
api.TodosFindTodosHandler = todos.FindTodosHandlerFunc(func(params todos.FindTodosParams) middleware.Responder {
return getToListHandler(api)
})
//goRx code which iterate over all items and handle it using observer model
func getToListHandler(api *operations.TodoListAPI) middleware.Responder {
watcher := observer.Observer{
NextHandler: func(item interface{}) {
ms, ok := item.(*models.Item)
if ok {
//How can write the response here i tried this but didnt work
result := middleware.ResponderFunc(func(rw
http.ResponseWriter, p runtime.Producer) {
rw.Write([]byte("hello"))
rw.WriteHeader(200)
})
//message just to use the result value to skip error
fmt.Println("result value of method '%v'", x)
})
}
},
// Register a handler for any emitted error.
ErrHandler: func(err error) {
//How can write the response here
},
// Register a handler when a stream is completed.
DoneHandler: func() {
//How can write the response here
},
}
it, _ := iterable.New(getAllTGoListMode())
source := observable.From(it)
sub := source.Subscribe(watcher)
<-sub
return middleware.NotImplemented("DONE....")
}
Как часть моего кода я хотел бы написать ответ напрямую как часть NextHandler, NextHandler, DoneHandler
Спасибо
Тони.