change sub ti since

Author: Gsantomaggio

examples/getting_started.go

@@ -110,7 +110,7 @@ func main() {
 		streamName,
 		handleMessages,
 		stream.NewConsumerOptions().
-			SetConsumerName("my_consumer"). // set a consumer name
+			SetConsumerName("my_consumer").                  // set a consumer name
 			SetOffset(stream.OffsetSpecification{}.First())) // start consuming from the beginning
 	CheckErr(err)
 	channelClose := consumer.NotifyClose()

examples/offsetTracking/offsetTracking.go

@@ -80,7 +80,7 @@ func main() {
 		streamName,
 		handleMessages,
 		stream.NewConsumerOptions().
-			SetConsumerName("my_consumer").            // set a consumer name
+			SetConsumerName("my_consumer").                         // set a consumer name
 			SetOffset(stream.OffsetSpecification{}.LastConsumed())) // start consuming from the beginning
 	CheckErr(err)
 

pkg/stream/client.go

@@ -326,7 +326,7 @@ func (c *Client) heartBeat() {
 				}
 				return
 			case <-ticker.C:
-				if time.Now().Sub(c.lastHeartBeat) > 60*time.Second {
+				if time.Since(c.lastHeartBeat) > 60*time.Second {
 					v := atomic.AddInt32(&heartBeatMissed, 1)
 					logs.LogWarn("Missing heart beat %d", v)
 					if v > 3 {

pkg/stream/server_frame.go

@@ -473,7 +473,6 @@ func (c *Client) closeFrameHandler(readProtocol *ReaderProtocol, r *bufio.Reader
 
 }
 
-
 func (c *Client) handleHeartbeat() {
 	c.lastHeartBeat = time.Now()
-}
+}