diff --git a/server.go b/server.go index d25bca654..d9552372f 100644 --- a/server.go +++ b/server.go @@ -31,7 +31,7 @@ type Server struct { streamCallback StreamCallback - newSession func(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback CloseCallback) packetHandler + newSession func(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback closeCallback) packetHandler } // NewServer makes a new server diff --git a/server_test.go b/server_test.go index be892fcea..3e548b614 100644 --- a/server_test.go +++ b/server_test.go @@ -25,7 +25,7 @@ func (s *mockSession) HandlePacket(addr interface{}, hdr *publicHeader, data []b func (s *mockSession) Run() { } -func newMockSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback CloseCallback) packetHandler { +func newMockSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback closeCallback) packetHandler { return &mockSession{ connectionID: connectionID, } diff --git a/session.go b/session.go index ffe59ebde..8376784b5 100644 --- a/session.go +++ b/session.go @@ -32,15 +32,15 @@ var ( // StreamCallback gets a stream frame and returns a reply frame type StreamCallback func(*Session, utils.Stream) -// CloseCallback is called when a session is closed -type CloseCallback func(id protocol.ConnectionID) +// closeCallback is called when a session is closed +type closeCallback func(id protocol.ConnectionID) // A Session is a QUIC session type Session struct { connectionID protocol.ConnectionID streamCallback StreamCallback - closeCallback CloseCallback + closeCallback closeCallback conn connection @@ -76,7 +76,7 @@ type Session struct { } // newSession makes a new session -func newSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback CloseCallback) packetHandler { +func newSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback closeCallback) packetHandler { stopWaitingManager := ackhandler.NewStopWaitingManager() session := &Session{ connectionID: connectionID,