@@ -0,0 +1,1055 @@
+package com.jborchardt.domain.feed;%0A%0Aimport org.junit.Test;%0A%0Aimport io.reactivex.observers.DisposableObserver;%0Aimport io.reactivex.schedulers.Schedulers;%0A%0Aimport static junit.framework.Assert.*;%0A%0Apublic class FeedInteractorTest %7B%0A%0A    @Test%0A    public void feed_results_arrive() throws Exception %7B%0A        final FeedRepository repository = new MockFeedRepository();%0A%0A        final FeedInteractor feedInteractor = new FeedInteractor(Schedulers.io(), Schedulers.io(), repository);%0A%0A        final DisposableObserver%3CFeedItem%3E observer = new DisposableObserver%3CFeedItem%3E() %7B%0A            private int mItemCount;%0A%0A            @Override%0A            public void onNext(final FeedItem value) %7B%0A                mItemCount++;%0A            %7D%0A%0A            @Override%0A            public void onError(final Throwable e) %7B%0A                fail();%0A            %7D%0A%0A            @Override%0A            public void onComplete() %7B%0A                assertEquals(MockFeedRepository.FEED_ITEMS, mItemCount);%0A            %7D%0A        %7D;%0A%0A        feedInteractor.fetchFeed(observer);%0A    %7D%0A%7D

Test for feed interaction