    @Test
    public void testGetFluxWeed() {


        //TODO Create a TestObserver
        TestObserver<Object> testObserver = TestObserver.create();
        //TODO subscribe to getFluxWeed()
        magicalDataSource.getFluxWeed().subscribe(testObserver);
        //TODO tell observer to wait for terminal event
        testObserver.awaitTerminalEvent();
        //TODO assert there are no errors
        testObserver.assertNoErrors();
        //TODO assert we received onComplete
        testObserver.assertComplete();

    }