MiraiForum

    • Register
    • Login
    • Search
    • Popular
    • Recent
    • Unsolved
    • Tags
    • Groups
    • 友情链接
    1. Home
    2. xielve
    X
    • Profile
    • Following 0
    • Followers 0
    • Topics 2
    • Posts 2
    • Best 0
    • Controversial 0
    • Groups 0

    xielve

    @xielve

    0
    Reputation
    1
    Profile views
    2
    Posts
    0
    Followers
    0
    Following
    Joined Last Online

    xielve Unfollow Follow

    Latest posts made by xielve

    • 请问事件通道怎么关闭?
      Listener<FriendMessageEvent> subscribe;
      
      @Override
      public void start() {
          subscribe = GlobalEventChannel.INSTANCE.subscribe(FriendMessageEvent.class, event -> {
              MessageChain message = event.getMessage();
              message.forEach(m -> {
                  if (m instanceof MessageContent) {
                      String str = m.contentToString();
                      event.getSubject().sendMessage(str);
                  }
              });
              return ListeningStatus.LISTENING;
          });
      }
      
      @Override
      public void stop() {
          System.out.println("结果==》" + subscribe.complete());
      }
      

      %(#55d929)[如果 handler 返回 ListeningStatus.STOPPED 监听器将被停止.
      也可以通过 subscribe 返回值 Listener 的 Listener.complete]

      posted in 开发交流
      X
      xielve