|
@@ -47,15 +47,18 @@ public:
|
|
|
return false;
|
|
|
|
|
|
// We don't want incoming() to be called by the lower layer anymore
|
|
|
- if (mLower)
|
|
|
+ if (mLower) {
|
|
|
+ PLOG_VERBOSE << "Unregistering incoming callback";
|
|
|
mLower->onRecv(nullptr);
|
|
|
-
|
|
|
+ }
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
void registerIncoming() {
|
|
|
- if (mLower)
|
|
|
+ if (mLower) {
|
|
|
+ PLOG_VERBOSE << "Registering incoming callback";
|
|
|
mLower->onRecv(std::bind(&Transport::incoming, this, _1));
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
void onRecv(message_callback callback) { mRecvCallback = std::move(callback); }
|