diff --git a/server/engine/engine.go b/server/engine/engine.go index d01ff82..1752a75 100644 --- a/server/engine/engine.go +++ b/server/engine/engine.go @@ -21,9 +21,9 @@ func NewEngine() *Engine { func (engine *Engine) Run() { for { value := engine.obs.Value().(handler.Value) - fmt.Printf("sleep: %d\n", value.Value) + fmt.Printf("sleep: %d\n", value.VersionRef) time.Sleep(1 * time.Second) - value.Value++ + value.VersionRef++ engine.obs.Update(value) } } diff --git a/server/handler/sync.go b/server/handler/sync.go index 3b6af8d..78ea410 100644 --- a/server/handler/sync.go +++ b/server/handler/sync.go @@ -8,21 +8,21 @@ import ( ) type Value struct { - Value int + VersionRef int } func SyncFactory(obs observer.Property) HandlerFunc { return func(w http.ResponseWriter, r *http.Request) { - refId, err := strconv.Atoi(r.URL.Query().Get("ref")) + versionRef, err := strconv.Atoi(r.URL.Query().Get("v")) if err != nil { - refId = -1 + versionRef = -1 } stream := obs.Observe() var value Value for { value = stream.Value().(Value) - if value.Value > refId { + if value.VersionRef >= versionRef { break } @@ -33,6 +33,6 @@ func SyncFactory(obs observer.Property) HandlerFunc { } w.Header().Add("Content-Type", "text/plain") - fmt.Fprintf(w, "%d (%d)\n", value.Value, refId) + fmt.Fprintf(w, "%d (%d)\n", value.VersionRef, versionRef) } }