When Observable drops msg on backpressure, it should call the onDrop method. This can be useful for incrementing some counter or just simply log something.