Go Swagger способность писать ответ для асинхронного реактивного кода - PullRequest
Новая
       26

Go Swagger способность писать ответ для асинхронного реактивного кода

0 голосов
/ 30 июня 2019

Я использую goswagger для генерации моего кода restAPI и как часть этого сгенерированного кода для написания ответов я должен вернуть middleware.Responder. Я хотел бы иметь возможность написать ответ напрямую, используя 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

Спасибо

Tony.

1 Ответ

0 голосов
/ 01 июля 2019

middleware.Responder - простой интерфейс с одним методом, который дает вам полный доступ к ответу и сериализаторам для этого типа содержимого ответа.

Вы можете взглянуть на этот пример: https://github.com/go-swagger/go-swagger/blob/master/examples/stream-server/restapi/configure_countdown.go#L43-L47

Он передает счетчик, но это тот же вариант использования.

...