// Close cancels underlying context and cancels ongoing requests.
Close cancels underlying context and cancels ongoing requests.
// Close cancels underlying context and cancels ongoing requests .
func (c *Client) Close() {
	c.streams.mu.RLock()
	defer c.streams.mu.RUnlock()
	for _, s := range c.streams.m {
		s.cancel()
	}
	c.client.Close()
	c.wg.Wait()
}
func ( c * Client ) Close ( ) { c . streams . mu . RLock ( ) defer c . streams . mu . RUnlock ( ) for _ , s := range c . streams . m { s . cancel ( ) } c . client . Close ( ) c . wg . Wait ( ) }
Close cancels underlying context and cancels ongoing requests.
Close cancels underlying context and cancels ongoing requests .