def test_single_or_default_async_predicate_throws(self):
        ex = 'ex'
        scheduler = TestScheduler()
        xs = scheduler.create_hot_observable(on_next(150, 1), on_next(210, 2), on_next(220, 3), on_next(230, 4), on_next(240, 5), on_completed(250))
        
        def create():
            def predicate(x):
                if 4 < x:
                    return False
                else:
                    raise Exception(ex)
            
            return xs.single_or_default(predicate, 0)
        res = scheduler.start(create=create)
        
        res.messages.assert_equal(on_error(230, ex))
        xs.subscriptions.assert_equal(subscribe(200, 230))
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_singleordefault.py/TestSingleOrDefault.test_single_or_default_async_predicate_throws/swapped operands of `<`