Commit9cf42df

committed

Remove channel from reconnect list when parting

1 parentb81e1e4 commit9cf42dfCopy full SHA for 9cf42df

File tree

+15

-0

lines changed

+15

-0

lines changed

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -119,6 +119,7 @@ func (c *Client) Join(channels ...string) {`
`119`	`119`
`120`	`120`	`func (c*Client)Part(channels...string) {`
`121`	`121`	`c.Write("PART "+strings.Join(channels,","))`
	`122`	`+c.removeChannels(channels...)`
`122`	`123`	`}`
`123`	`124`
`124`	`125`	`func (c*Client)Topic(channelstring,topic...string) {`
`@@ -183,6 +184,18 @@ func (c *Client) addChannel(channel string) {`
`183`	`184`	`c.lock.Unlock()`
`184`	`185`	`}`
`185`	`186`
	`187`	`+func (c*Client)removeChannels(channels...string) {`
	`188`	`+c.lock.Lock()`
	`189`	`+for_,removeCh:=rangechannels {`
	`190`	`+fori,ch:=rangec.channels {`
	`191`	`+ifc.EqualFold(removeCh,ch) {`
	`192`	`+c.channels=append(c.channels[:i],c.channels[i+1:]...)`
	`193`	`+}`
	`194`	`+}`
	`195`	`+}`
	`196`	`+c.lock.Unlock()`
	`197`	`+}`
	`198`	`+`
`186`	`199`	`func (c*Client)flushChannels() {`
`187`	`200`	`c.lock.Lock()`
`188`	`201`	`iflen(c.channels)>0 {`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -162,6 +162,8 @@ func TestFlushChannels(t *testing.T) {`
`162`	`162`	`c.flushChannels()`
`163`	`163`	`assert.Equal(t,<-out,"JOIN #chan1\r\n")`
`164`	`164`	`c.addChannel("#chan2")`
	`165`	`+c.addChannel("#chan4")`
	`166`	`+c.removeChannels("#chan4")`
`165`	`167`	`c.addChannel("#chan3")`
`166`	`168`	`c.flushChannels()`
`167`	`169`	`assert.Equal(t,<-out,"JOIN #chan2,#chan3\r\n")`

Comments

(0)