Building Microservices with .NET Core 2.0 - Second Edition

Communication between the application and the database

With our context in place, and taking care of the communication between our application and the database, let's go ahead and add a repository for facilitating interaction between our data models and our database. Please refer to the code for our repository, as discussed in step 10 of the Creating the project section.

Marking our result from GetAll as IObservable adds the reactive functionality we are looking for. Also, pay special attention to the return statement.

With this observable model, it becomes possible for us to handle streams of asynchronous events with the same ease we are used to when handling other, simpler collections:

 return Observable.Return(GetProducts());

We are now ...