gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

use streams in example server

Browse Source
This commit is contained in:
Lucas Clemente
2016-04-18 14:09:29 +02:00
parent 9757ad62f2
commit e9967e990a
2 changed files with 13 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
example/main.go
View File

@@ -9,7 +9,6 @@ import (
"golang.org/x/net/http2/hpack"
"github.com/lucas-clemente/quic-go"
"github.com/lucas-clemente/quic-go/frames"
"github.com/lucas-clemente/quic-go/protocol"
)
@@ -32,13 +31,13 @@ func main() {
}
}
func handleStream(session *quic.Session, stream *quic.Stream) []frames.Frame {
var reply bytes.Buffer
h2framer := http2.NewFramer(&reply, stream)
func handleStream(session *quic.Session, stream *quic.Stream) {
h2framer := http2.NewFramer(stream, stream)
h2framer.ReadMetaHeaders = hpack.NewDecoder(1024, nil)
h2frame, err := h2framer.ReadFrame()
if err != nil {
return nil
fmt.Printf("invalid http2 frame: %s", err.Error())
return
}
h2headersFrame := h2frame.(*http2.MetaHeadersFrame)
fmt.Printf("Request: %s %s://%s%s\n", h2headersFrame.PseudoValue("method"), h2headersFrame.PseudoValue("scheme"), h2headersFrame.PseudoValue("authority"), h2headersFrame.PseudoValue("path"))
@@ -53,17 +52,13 @@ func handleStream(session *quic.Session, stream *quic.Stream) []frames.Frame {
EndHeaders: true,
BlockFragment: replyHeaders.Bytes(),
})
headerStreamFrame := &frames.StreamFrame{
StreamID: stream.StreamID,
Data: reply.Bytes(),
FinBit: true,
dataStream, err := session.NewStream(protocol.StreamID(h2frame.Header().StreamID))
if err != nil {
fmt.Printf("error creating stream: %s", err.Error())
return
}
dataStreamFrame := &frames.StreamFrame{
StreamID: protocol.StreamID(h2frame.Header().StreamID),
Data: []byte("Hello World!"),
FinBit: true,
}
return []frames.Frame{headerStreamFrame, dataStreamFrame}
dataStream.Write([]byte("Hello World!"))
dataStream.Close()
}