Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix: Fix typos #398

Merged
merged 1 commit into from Jan 21, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
2 changes: 1 addition & 1 deletion client.go
Expand Up @@ -794,7 +794,7 @@ func (c *client) SubscribeMultiple(filters map[string]byte, callback MessageHand
return token
}

// reserveStoredPublishIDs reserves the ids for publish packets in the persistant store to ensure these are not duplicated
// reserveStoredPublishIDs reserves the ids for publish packets in the persistent store to ensure these are not duplicated
func (c *client) reserveStoredPublishIDs() {
// The resume function sets the stored id for publish packets only (some other packets
// will get new ids in net code). This means that the only keys we need to ensure are
Expand Down
2 changes: 1 addition & 1 deletion fvt_client_test.go
Expand Up @@ -1308,7 +1308,7 @@ func Test_ResumeSubsWithReconnect(t *testing.T) {
t.Fatalf("Connect returned error (%v)", sConnToken.Error())
}

// Send subscription request and then immediatly force disconnect (hope it will happen before sub sent)
// Send subscription request and then immediately force disconnect (hope it will happen before sub sent)
subToken := newToken(packets.Subscribe).(*SubscribeToken)
sub := packets.NewControlPacket(packets.Subscribe).(*packets.SubscribePacket)
sub.Topics = append(sub.Topics, topic)
Expand Down
2 changes: 1 addition & 1 deletion websocket.go
Expand Up @@ -11,7 +11,7 @@ import (
"github.com/gorilla/websocket"
)

// NewWebsocket returns a new websocket and returns a net.Conn compatiable interface using the gorilla/websocket package
// NewWebsocket returns a new websocket and returns a net.Conn compatible interface using the gorilla/websocket package
func NewWebsocket(host string, tlsc *tls.Config, timeout time.Duration, requestHeader http.Header) (net.Conn, error) {
if timeout == 0 {
timeout = 10 * time.Second
Expand Down