使用JavaRx/rx-mongodb下载grails中的文件

Question

我正尝试在Grails 3.2.1中下载文件。我有一个名为“文件”的org.bson.types.Binary类型保存在mongo-db中。存储的文件的大小以kb为单位，因此不需要GridFS。

我可以使用org.bson.types.Binary提供的getData（）辅助函数来访问byte []。使用标准蒙戈-DB驱动程序，我可以用下面的实现： -

class DownloadController { 

    def stream() { 
    def fileDB = FileDB.get(params.id) 
    if(fileDB) { 
     response.setContentType(fileDB.contentType) 
     response.setHeader("Content-disposition", "filename=${fileDB.id}.wav") 
     response.outputStream << fileDB.file.getData() 
    } else { 
     //handle error 
    } 
    } 


} 

随着蒙戈的Rx驱动程序，更具体RxJava。如何从Observer订阅下载文件？ Grails提供了一个RxController，它为rx.render和rx.respond提供助手，但是我无法得到回应。 TBH，我试图让我的头绕过ReactiveX！这是我到目前为止： -

class DownloadController implements RxController { 

    def stream() { 

     FileDB.get((Serializable) params.id).subscribe({ fileDB fileDB-> 
      //How do I handle this?? 
      response.setContentType(fileDB.contentType) 
      response.setHeader("Content-disposition", "filename=${fileDB.id}.wav") 
      response.outputStream << fileDB.file.getData() 
     }) 

    } 

} 

任何意见也将不胜感激。

Answer 1

这应该起作用。它使用渲染方法（请参阅http://mrhaki.blogspot.com.es/2013/09/grails-goodness-render-binary-output.html）。如果没有，请报告问题：

def stream() { 

    FileDB.get((Serializable) params.id).subscribe({ fileDB fileDB-> 
     rx.render(fileName:"${fileDB.id}.wav", 
        file:fileDB.file.getData(), 
        contentType:fileDB.contentType) 
    }) 

} 

Answer 2

你可以试试以下（代码段将是在Java /常规“伪”） `

Observable<Response> response = ...; 
    Observable<FileDB> fileDb = FileDB.get(params.id); 
    Observable<Response> processedResponse = response.zipWith(
      fileDb.filter(content != null) 
       .switchIfEmpty(Observable.error(new RuntimeException())), 
      (resp, file) -> { 
       resp.setContentType(file.contentType) 
       resp.setHeader("Content-disposition", "filename=${fileDB.id}.wav") 
       resp.outputStream << fileDB.file.getData()  

       return resp; 
      }); 

processedResponse 
    .subscribeOn(Shedulers.io()) 
    .subscribe(response -> {/*save response*/}, error -> {/*handle error*/}); 

的想法是拉链Response与FileDB观察到的，但发出错误，如果文件为空。如果您同时获得Response，请将其包装为Observable.just(resp)