trivial.

lichao

2021-05-18 9f9d05d8cfb8076a4067a0e3c7561781521225ed

 src/topic_node.cpp

@@ -107,14 +107,9 @@
               }
               SetProcIndex(reply.proc_index());
               this->state_ = eStateUnregistered;
               auto onRequest = [this](ShmSocket &socket, MsgI &msg, BHMsgHead &head) {
                  server_buffer_->Write(std::move(head), msg.body());
               };
               SockServer().Start(onRequest);
               auto onSub = [this](ShmSocket &socket, MsgI &msg, BHMsgHead &head) {
                  sub_buffer_->Write(std::move(head), msg.body());
               };
               SockSub().Start(onSub);

               ServerStart(ServerAsyncCB(), 1);
               SubscribeStartWorker(SubDataCB(), 1);
            }
         } break;
         default: break;