rsocket / rsocket-dart

Dart implementation of RSocket
Apache License 2.0
31 stars 25 forks source link

AuthMetadata Jwt 请求响应模式没有任何 结果 也没有错误 #27

Closed sdack-cloud closed 1 year ago

sdack-cloud commented 1 year ago
var metadata = CompositeMetadata.fromEntries([
      AuthMetadata.jwt(_token),
      RoutingMetadata("user.get",[]),
    ]);
    var users = Users.create();
    users.meta = _meta;
    users.id = Int64(_account!.id.toInt());
    var userBuf = users.writeToBuffer();
    var meta = metadata.toUint8Array();
    var compositeMetadata2 = CompositeMetadata.fromU8Array(meta);
    compositeMetadata2.forEach((entry) {
      print('mimeType: ' +
          entry.mimeType! +
          ', content: ' +
          entry.content!.length.toString());
    });
    var payload = Payload.from(meta, userBuf);
    _rSocket!.requestResponse!(payload).then((value) {
      var data = value.data!;
      Users users = Users.fromBuffer(data);
      var user = IMIOUsers().toProto(users);
      _meta.roomId = Int64(user.roomId.toInt());
      _account!.avatar = user.avatar;
      _account!.nickname = user.nickname;
      _account!.account = user.account;
    }).catchError((e) {
      var message = e.toString();
      if (message.contains("401")) {
        _getToken();
      }
    }).onError((error, stackTrace) {
      print(error.toString());
      stackTrace.toString();
    });

我那些地方不正确嘛 @linux-china