fix retain publish with options

kelindar · kelindar · commit 6dc4f08d6ee5 · 2019-03-03T19:33:18.000+08:00
diff --git a/v2/emitter.go b/v2/emitter.go
@@ -259,7 +259,8 @@ func (c *Client) PublishWithTTL(key string, channel string, payload interface{},
 
 // PublishWithRetain publishes a message with a retain flag set to true
 func (c *Client) PublishWithRetain(key string, channel string, payload interface{}, options ...Option) error {
-	return c.Publish(key, channel, payload, WithRetain())
+	options = append(options, WithRetain())
+	return c.Publish(key, channel, payload, options...)
 }
 
 // PublishWithLink publishes a message with a specified link name instead of a channel key.

Original file line number	Diff line number	Diff line change
`@@ -259,7 +259,8 @@ func (c *Client) PublishWithTTL(key string, channel string, payload interface{},`
`259`	`259`
`260`	`260`	`// PublishWithRetain publishes a message with a retain flag set to true`
`261`	`261`	`func (c *Client) PublishWithRetain(key string, channel string, payload interface{}, options ...Option) error {`
`262`		`- return c.Publish(key, channel, payload, WithRetain())`
	`262`	`+ options = append(options, WithRetain())`
	`263`	`+ return c.Publish(key, channel, payload, options...)`
`263`	`264`	`}`
`264`	`265`
`265`	`266`	`// PublishWithLink publishes a message with a specified link name instead of a channel key.`