|
@@ -26,8 +26,7 @@ async fn remove_sub_on_stop(p2p: P2pPtr, channel: ChannelPtr) {
|
|
|
|
|
|
|
|
#[async_trait]
|
|
#[async_trait]
|
|
|
pub trait Session: Sync {
|
|
pub trait Session: Sync {
|
|
|
- /// Registers a new channel with the session. Performs a network handshake and starts the
|
|
|
|
|
- /// channel.
|
|
|
|
|
|
|
+ /// Registers a new channel with the session. Performs a network handshake and starts the channel.
|
|
|
async fn register_channel(
|
|
async fn register_channel(
|
|
|
self: Arc<Self>,
|
|
self: Arc<Self>,
|
|
|
channel: ChannelPtr,
|
|
channel: ChannelPtr,
|