diff --git a/client/client.go b/client/client.go index d2aabf1..4d4d38c 100644 --- a/client/client.go +++ b/client/client.go @@ -54,6 +54,8 @@ func (c *client) Start(rwc io.ReadWriteCloser) { c.stopChan = make(chan struct{}) c.requestQueueChan = make(chan *CallState, c.ch.GetPendingRequests()) + c.ch.OnStart() + c.stopWg.Add(1) go handleRPC(c) }