src/socket.cpp
@@ -52,7 +52,7 @@ auto DoRecv = [=] { auto onRecvWithPerMsgCB = [this, onData](ShmSocket &socket, MsgI &imsg, BHMsgHead &head) { RecvCB cb; if (per_msg_cbs_->Find(head.msg_id(), cb)) { if (per_msg_cbs_->Pick(head.msg_id(), cb)) { cb(socket, imsg, head); } else if (onData) { onData(socket, imsg, head);