<s> import logging <EOL> from datetime import datetime , timedelta <EOL> from rx import Observable <EOL> from rx . testing import TestScheduler , ReactiveTest , is_prime , MockDisposable <EOL> from rx . disposables import Disposable , SerialDisposable <EOL> FORMAT = '<STR_LIT>' <EOL> logging . basicConfig ( filename = '<STR_LIT>' , format = FORMAT , level = logging . DEBUG ) <EOL> log = logging . getLogger ( '<STR_LIT>' ) <EOL> on_next = ReactiveTest . on_next <EOL> on_completed = ReactiveTest . on_completed <EOL> on_error = ReactiveTest . on_error <EOL> subscribe = ReactiveTest . subscribe <EOL> subscribed = ReactiveTest . subscribed <EOL> disposed = ReactiveTest . disposed <EOL> created = ReactiveTest . created <EOL> class RxException ( Exception ) : <EOL> pass <EOL> def _raise ( ex ) : <EOL> raise RxException ( ex ) <EOL> if __name__ == '<STR_LIT:__main__>' : <EOL> test_buffer_with_time_or_count_basic ( ) </s>
