Observable Integration

Hello,

I am having trouble figuring out how to use Observables with GridFS to upload and download files into Mongo using scala latest driver (4.2.3). The examples I saw were lacking. We used to use AsyncInputStream, but that got deprecated with the latest version. Any help will be appreciated.

This file has good examples, I’ll try them: