func (c *partitionConsumer) Close() error {
	c.AsyncClose()
	<-c.dead
	return c.closeErr
}
func (c *partitionConsumer) Close() error {
	c.AsyncClose()
	<-c.dead
	return c.closeErr
}
func ( c * partitionConsumer ) Close ( ) error { c . AsyncClose ( ) <- c . dead return c . closeErr }
// Close implements PartitionConsumer
Close implements PartitionConsumer