Eu sou muito novo emRxJava (e paradigma reativo em geral), por isso, tenha paciência comigo.

Suponha que eu tenho issoNews e isso aninhadoComment estrutura de dados:

public class News {
  public int id;
  public int[] commentIds; //only top level comments
  public News(int id, int[] commentIds) {
    this.id = id;
    this.commentIds = commentIds;
  }
}

public class Comment {
  public int id;
  public int parentId; //ID of parent News or parent comment
  public int[] childIds;
  public Comment(int id, int parentId, int[] childIds) {
    this.id = id;
    this.parentId = parentId;
    this.childIds = childIds;
  }
}

e suponha que eu tenho este ponto de extremidade da API:

getComments(int commentId) //return Observable<Comment> for Comment with ID commentId

Agora, vamos assumir:

getComments(1); //will return Comment(1, 99, [3,4])
getComments(2); //will return Comment(2, 99, [5,6])
getComments(3); //will return Comment(3, 1, [])
getComments(4); //will return Comment(4, 1, [])
getComments(5); //will return Comment(5, 2, [])
getComments(6); //will return Comment(6, 2, [])

**

Agora, se eu tiverNews n = News(99, [1,2]), como faço para que todos os seus filhos comentem recursivamente? ou seja, para obter comentários com o ID [1,2,3,4,5,6]?

**

Eu procurei e me deparei com isso:https://jkschneider.github.io/blog/2014/recursive-observables-with-rxjava.html

Esta é a função de recursão:

public class FileRecursion {
    static Observable<File> listFiles(File f) {
        if(f.isDirectory())
            return Observable.from(f.listFiles()).flatMap(FileRecursion::listFiles);
        return Observable.just(f);
    }

    public static void main(String[] args) {
          Observable.just(new File("/Users/joschneider/Desktop"))
                  .flatMap(FileRecursion::listFiles)
                  .subscribe(f -> System.out.println(f.getAbsolutePath()));
    }
}

Ele mostra um exemplo de como fazer chamadas observáveis recursivas, mas a função interna (f.listFiles()) é uma operação de bloqueio (não retorna outro Observable). No meu caso, a função interna (getComments) é uma função sem bloqueio que retorna outros Observáveis. Como faço isso?

Qualquer ajuda será muito apreciada.