Skip to content

Commit

Permalink
feat: allow to create a session directly
Browse files Browse the repository at this point in the history
  • Loading branch information
berezovskyi-oleksandr committed Nov 16, 2023
1 parent db10053 commit 6655e4a
Showing 1 changed file with 9 additions and 3 deletions.
12 changes: 9 additions & 3 deletions gpsd.go
Original file line number Diff line number Diff line change
Expand Up @@ -205,17 +205,23 @@ func DialTimeout(address string, to time.Duration) (*Session, error) {
return dialCommon(net.DialTimeout("tcp4", address, to))
}

func NewSession(c net.Conn, reader *bufio.Reader) (session *Session, e error) {
return newSessionCommon(c, reader, nil)
}

func dialCommon(c net.Conn, err error) (session *Session, e error) {
return newSessionCommon(c, bufio.NewReader(c), err)
}

func newSessionCommon(c net.Conn, reader *bufio.Reader, err error) (session *Session, e error) {
session = new(Session)
session.socket = c
if err != nil {
return nil, err
}

session.reader = bufio.NewReader(session.socket)
session.reader.ReadString('\n')
session.reader = reader
session.filters = make(map[string][]Filter)

return
}

Expand Down

0 comments on commit 6655e4a

Please sign in to comment.