public static PipeSubscribeUnsubscribeReq fromTPipeSubscribeReq(
      final TPipeSubscribeReq unsubscribeReq) {
    final PipeSubscribeUnsubscribeReq req = new PipeSubscribeUnsubscribeReq();

    if (Objects.nonNull(unsubscribeReq.body) && unsubscribeReq.body.hasRemaining()) {
      req.topicNames = ReadWriteIOUtils.readObjectSet(unsubscribeReq.body);
    }

    req.version = unsubscribeReq.version;
    req.type = unsubscribeReq.type;
    req.body = unsubscribeReq.body;

    return req;
  }
Deserialize `TPipeSubscribeReq` to obtain parameters, called by the subscription server.
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeUnsubscribeReq.java