发挥作用的能力，可以为异步反应代码编写响应

Question

我正在使用goswagger生成我的RESTAPI代码，作为此生成的代码的一部分，我应该返回Middleware.Responder。我想在使用Gorx Reactive扩展时直接使用API客户端编写响应的选项，这是在异步模式下运行的值。

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

谢谢

托尼。

Answer 1

middleware.responder是一个简单的一种方法界面，可让您完全访问该响应内容类型的响应和串行化。

您可以查看此示例：https：//github.com/go-swagger/go-swagger/blob/blob/master/master/examples/stream-server/restapi/restapi/configure_countdown.go#l43-l43-l47

它流式传输柜台，但是相同的用例。