class StreamService {

  public List<StreamSession> listStreams(Node node) throws ReaperException {
    try {
      LOG.debug("Pulling streams for node {}", node);
      return pullStreamInfo(node);
    } catch (ReaperException | InterruptedException | IOException e) {
      LOG.info("Pulling streams failed: {}", e.getMessage());
      throw new ReaperException(e);
    }
  }

  private  StreamService(Supplier<ClusterFacade> clusterFacadeSupplier);

}