Simple RESTful pipeline

main.go

package main

import (
	"fmt"
	"io"
	"io/ioutil"
	"net/http"
)

/*
curl -i -X PUT localhost:8080 -d 'a'
curl -i -X GET localhost:8080
*/

var messages = make(chan string, 3)

func main() {
	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		fmt.Println(r.Method, r.Host)
		switch r.Method {
		case "GET":
			io.WriteString(w, <-messages)
		case "PUT":
			body, err := ioutil.ReadAll(r.Body)
			if err != nil {
				return
			}
			messages <- string(body)
		}
	})
	http.ListenAndServe(":8080", nil)
}