@Test
public void getRemainingScansStream() {

    final BehaviorSubject<Integer> scansStream = BehaviorSubject.createDefault(50);
    when(localOcrScansTracker.getRemainingScansStream()).thenReturn(scansStream);
    ocrPurchaseTracker.getRemainingScansStream().test()
            .assertValue(50)
            .assertNotComplete()
            .assertNoErrors();
}