RxGo Rest api example

[DennisMuchiri]

I'm requesting an example on how to use this library to emit items in a Rest API GET

[Alfex4936]

I think simplest api would be something like this

package main

import (
    "context"
    "fmt"
    "log"
    "net/http"

    "github.com/reactivex/rxgo/v2"
)

type WebFramework struct {
    router map[string]rxgo.Observable
}

func NewWebFramework() *WebFramework {
    return &WebFramework{
        router: make(map[string]rxgo.Observable),
    }
}

// Observable handler
func (wf *WebFramework) Handle(path string, handler rxgo.Observable) {
    wf.router[path] = handler
}

func (wf *WebFramework) Start(port int) error {
    log.Printf("💕 Starting server at %d", port)
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        if observable, ok := wf.router[r.URL.Path]; ok {
            ch := observable.Observe()
            for item := range ch {
                if item.Error() {
                    http.Error(w, item.E.Error(), http.StatusInternalServerError)
                    return
                }
                fmt.Fprintln(w, item.V)
            }
        } else {
            http.NotFound(w, r)
        }
    })

    return http.ListenAndServe(fmt.Sprintf(":%d", port), nil)
}

func main() {
    wf := NewWebFramework()

    // an observable that emits integers, transforms them to strings, and filters by a condition
    observable := rxgo.Just(1, 2, 3, 4, 5)().
        Map(func(_ context.Context, item interface{}) (interface{}, error) {
            num := item.(int)
            return fmt.Sprintf("%d", num*num), nil
        }).
        Filter(func(item interface{}) bool {
            str := item.(string)
            return str[0] == '1' // simple filter to demonstrate, checks if the first char is '1'
        })

    // Register an HTTP path with the observable
    wf.Handle("/data", observable)

    // Start the server on port 8080
    err := wf.Start(8080)
    if err != nil {
        fmt.Println("Failed to start server:", err)
    }
}