forked from quic-go/quic-go
log stream closes
This commit is contained in:
@@ -1,6 +1,8 @@
|
|||||||
package quic
|
package quic
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
"github.com/lucas-clemente/quic-go/frames"
|
"github.com/lucas-clemente/quic-go/frames"
|
||||||
"github.com/lucas-clemente/quic-go/protocol"
|
"github.com/lucas-clemente/quic-go/protocol"
|
||||||
"github.com/lucas-clemente/quic-go/utils"
|
"github.com/lucas-clemente/quic-go/utils"
|
||||||
@@ -120,6 +122,7 @@ func (s *Stream) Write(p []byte) (int, error) {
|
|||||||
|
|
||||||
// Close imlpements io.Closer
|
// Close imlpements io.Closer
|
||||||
func (s *Stream) Close() error {
|
func (s *Stream) Close() error {
|
||||||
|
fmt.Printf("Closing stream %d\n", s.StreamID)
|
||||||
return s.Session.SendFrame(&frames.StreamFrame{
|
return s.Session.SendFrame(&frames.StreamFrame{
|
||||||
StreamID: s.StreamID,
|
StreamID: s.StreamID,
|
||||||
Offset: s.WriteOffset,
|
Offset: s.WriteOffset,
|
||||||
|
|||||||
Reference in New Issue
Block a user