Elara6331/lrpc
Archived
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix call to lrpc.ChannelDone

Browse Source
This commit is contained in:
Elara 2022-05-01 15:17:46 -07:00
parent b53388122c
commit f1aa0f5c4f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client/main.go
View File

@ -144,7 +144,7 @@ func (c *Client) Call(ctx context.Context, rcvr, method string, arg interface{},
{Dir: reflect.SelectRecv, Chan: ctxDoneVal, Send: reflect.Value{}}, {Dir: reflect.SelectRecv, Chan: ctxDoneVal, Send: reflect.Value{}},
}) })
if chosen == 1 { if chosen == 1 {
c.Call(context.Background(), "lrpc", "ChannelDone", id, nil) c.Call(context.Background(), "lrpc", "ChannelDone", chID, nil)
// Close and delete channel // Close and delete channel
c.chMtx.Lock() c.chMtx.Lock()
close(c.chs[chID]) close(c.chs[chID])