func (x *logBrokerPublishLogsClient) CloseAndRecv() (*PublishLogsResponse, error) {
    if err := x.ClientStream.CloseSend(); err != nil {
        return nil, err
    }
    m := new(PublishLogsResponse)