proxy

Dec 10, 2016

Changes in this version

+ type HTTPReader struct

+ Buffered []byte

+ Chan <-chan string

+ EOF bool

+ MessageKey string

+ func (h *HTTPReader) Close() error

+ func (h *HTTPReader) Read(bytes []byte) (int, error)

+ type HTTPWriter struct

+ Chan chan<- common.Message

+ Message common.HTTPMessage

+ MessageKey string

+ func (h *HTTPWriter) Close() error

+ func (h *HTTPWriter) Write(bytes []byte) (n int, err error)

+ type Handler struct

+ func (s *Handler) Handle(key string, initialMessage string, incomingMessages <-chan string, ...)