<s> from stream_framework . tests . feeds . aggregated_feed . base import TestAggregatedFeed <EOL> from stream_framework . feeds . aggregated_feed . notification_feed import RedisNotificationFeed <EOL> class TestNotificationFeed ( TestAggregatedFeed ) : <EOL> feed_cls = RedisNotificationFeed <EOL> def test_mark_all ( self ) : <EOL> self . test_feed . insert_activities ( self . aggregated . activities ) <EOL> self . test_feed . add_many_aggregated ( [ self . aggregated ] ) <EOL> assert len ( self . test_feed [ : <NUM_LIT:10> ] ) == <NUM_LIT:1> <EOL> assert int ( self . test_feed . count_unseen ( ) ) == <NUM_LIT:1> <EOL> self . test_feed . mark_all ( ) <EOL> assert int ( self . test_feed . count_unseen ( ) ) == <NUM_LIT:0> <EOL> assert int ( self . test_feed . get_denormalized_count ( ) ) == <NUM_LIT:0> </s>
