U
vâ’i ã @ sj d dl mZmZ d dlmZ d dlmZmZmZ d dl m
Z
ddl m Z edƒZ
G dd „ d eje
ƒZd
S ) é )ÚListÚTypeVar)Úabc)Ú OnCompletedÚOnErrorÚOnNext)ÚVirtualTimeScheduleré )ÚRecordedÚ_Tc @ sJ e Zd Zeddœdd„Zeddœdd„Zeddœd d
„Zdd œd d
„Z dS )Ú MockObserverN)Ú schedulerÚreturnc C s || _ g | _d S ©N)r
Úmessages)Úselfr
© r úO/opt/alt/python38/lib/python3.8/site-packages/reactivex/testing/mockobserver.pyÚ__init__
s zMockObserver.__init__)Úvaluer c C s | j t| jjt|ƒƒ¡ d S r )r Úappendr
r
Úclockr )r r r r r Úon_next s zMockObserver.on_next)Úerrorr c C s | j t| jjt|ƒƒ¡ d S r )r r r
r
r r )r r r r r Úon_error s zMockObserver.on_error)r c C s | j t| jjtƒ ƒ¡ d S r )r r r
r
r r )r r r r Ú on_completed s zMockObserver.on_completed)
Ú__name__Ú
__module__Ú __qualname__r r r r Ú Exceptionr r r r r r r s r N)Útypingr r Z reactivexr Zreactivex.notificationr r r Zreactivex.schedulerr Zrecordedr
r Z ObserverBaser r r r r Ú s