RxJava Subjects are observable’s and observers at the same time. Because they can be both, they can subscribe to an other observable’s and because it is self an observable, it can pass through the items it observes by re-emitting them. It can also emit new items. As a result, a subject can subscribe to an … More Creating RxJava Subjects
RxJava is a very useful library for asynchronous and event-based programming, also called reactive programming. There are two main actors in RxJava: Observables — An object that emits a stream of data or events Observers/Subscribers — An object that acts upon the emitted data. An observer is an object which know how to act upon 3 sort of … More Creating Observables and Subscribers in RxJava
Search engines retrieves a number of documents as a result for a query. However, the relevance of the result can also be checked by consulting the users. For the details, see Cranfield Evaluation Methodology. Depending on the user group, different users might find different result sets more relevant. Depending on the context, sometimes, a user … More Precision and Recall calculation for Search Engines
The use of inverse document frequency is eliminating the false weight of popular terms in the index (all documents). Example: In a document like : “quick brown fox”, the word count of brown is probably much higher in the index so it is likely much more common than the word fox. In a search query like … More IDF – Inverse Document Frequency
Reactive programming can be achieved on several ways. Below a short list of technologies and frameworks in Java landscape. Executor service in combination of Futures. For fire and forget implementations, use Runnable threads. For implementations whereby a response is required (Fork-Join), use a Callable implementation. ExecutorCompletionService (Producer-Consumer approach). Asynchronous service calls. This can be achieved … More Reactive processing methods
In Java, creating a local HTTP server is very easy. You can add more context to handle more HTTP paths.