Method ~PartitionChannel

src/brpc/partition_channel.cpp:198–209

}

PartitionChannel::~PartitionChannel() {
    if (_nsthread_ptr) {
        if (_pchan) {
            _nsthread_ptr->RemoveWatcher(_pchan);
        }
        _nsthread_ptr.reset();
    }
    delete _pchan;
    _pchan = NULL;
    delete _parser;
    _parser = NULL;
}

int PartitionChannel::Init(int num_partition_kinds,
                           PartitionParser* partition_parser,