add async recv suport; sync by waiting for async.

lichao

2021-03-31 3c2b6739208d961cf8b86460d7f05516d044960c

 proto/source/bhome_msg.proto

@@ -25,6 +25,8 @@
   kMsgTypePublish = 3;
   kMsgTypeSubscribe = 4;
   kMsgTypeUnsubscribe = 5;
   kMsgTypeQueryTopic = 6;
   kMsgTypeQueryTopicReply = 7;
}

message DataPub {
@@ -35,3 +37,20 @@
message DataSub {
   repeated bytes topics = 1;
}

message DataRequest {
   bytes topic = 1;
   bytes data = 2; 
}

message DataReply {
   bytes data = 1; 
}

message DataQueryTopic {
   bytes topic = 1;
}

message DataQueryTopicReply {
   BHAddress address = 1;
}