httpstream

type Connection interface {
	io.Closer
	CloseWait() error
	CreateStream(headers http.Header) (Stream, error)
}

type NewStreamHandler func(Stream)

type RequestStreamer interface {
	Stream3(req *http.Request, doStdin, doStdout, doStderr, tty bool) (stdin io.WriteCloser, stdout, stderr io.Reader, err error)
	Wait()
}

type RequestUpgrader interface {
	Upgrade(request *http.Request, newStreamHandler NewStreamHandler) (Connection, error)
}

type ResponseStreamer interface {
	StreamResponse(w http.ResponseWriter, req *http.Request) (stdin io.Reader, stdout, stderr io.WriteCloser, err error)
	Wait()
}

type ResponseUpgrader interface {
	Upgrade(w http.ResponseWriter, req *http.Request, newStreamHandler NewStreamHandler) (Connection, error)
}

type Stream interface {
	io.ReadWriteCloser
	GetHeader(key string) string
}