val subscriber: (M.(String) -> Boolean, MessageListener<M, RR>) -> Ret
invoke 这个 lambda 时, 它将会把 消息事件的处理器 注册给事件, 并返回注册完成返回的监听器.