U
vâ’iG ã @ s² d dl Z d dlZd dlmZmZmZmZ d dlmZ d dlm Z m
Z
m Z ddl m
Z
ddlmZ edƒZeed œd
d „ZG d d
„ d
ee ƒZG dd„ dee ƒZG dd„ dƒZdS )é N)ÚAnyÚGenericÚTypeVarÚUnion)Útyping)Ú OnCompletedÚOnErrorÚOnNexté )ÚRecorded©Ú SubscriptionÚ_T)ÚiÚreturnc C sF | dkr dS t t t | ¡¡ƒ}td|d ƒD ]}| | s. dS q.dS )z Tests if number is prime or notr
Fé T)ÚintÚmathÚfloorÚsqrtÚrange)r Ú_maxÚj© r úO/opt/alt/python38/lib/python3.8/site-packages/reactivex/testing/reactivetest.pyÚis_prime s r c @ s2 e Zd Zeje ddœdd„Zeedœdd„Z dS )ÚOnNextPredicateN)Ú predicater c C s
|| _ d S ©N©r ©Úselfr r r r Ú__init__ s zOnNextPredicate.__init__©Úotherr c C s2 || kr dS |d krdS |j dkr&dS | |j¡S )NTFÚN)Úkindr Úvalue©r! r$ r r r Ú__eq__! s
zOnNextPredicate.__eq__©
Ú__name__Ú
__module__Ú __qualname__r Z Predicater r" r Úboolr) r r r r r s r c @ s0 e Zd Zeje dœdd„Zeedœdd„Z dS )ÚOnErrorPredicater c C s
|| _ d S r r r r r r r" , s zOnErrorPredicate.__init__r# c C s2 || kr dS |d krdS |j dkr&dS | |j¡S )NTFÚE)r& r Ú exceptionr( r r r r) / s
zOnErrorPredicate.__eq__Nr* r r r r r/ + s r/ c @ s† e Zd ZdZdZdZeeee e dœdd„ƒZ
eee e e
ejf e e dœdd „ƒZeee e d
œd d „ƒZeeeed
œdd„ƒZdS )Ú ReactiveTestéd éÈ iè )Úticksr' r c C s( t |tjƒrt| t|ƒƒS t| t|ƒƒS r )Ú
isinstanceÚtypesÚ FunctionTyper r r )r5 r' r r r Úon_next> s zReactiveTest.on_next)r5 Úerrorr c C s( t |tjƒrt| t|ƒƒS t| t|ƒƒS r )r6 r7 r8 r r/ r )r5 r: r r r Úon_errorE s zReactiveTest.on_error)r5 r c C s t | tƒ ƒS r )r r )r5 r r r Ú on_completedN s zReactiveTest.on_completed)ÚstartÚendr c C s
t | |ƒS r r )r= r> r r r Ú subscribeR s zReactiveTest.subscribeN)r+ r, r- ÚcreatedZ
subscribedZdisposedÚ staticmethodr r r r9 r Ú ExceptionÚstrr7 r8 r r; r< r
r? r r r r r2 9 s þr2 )r r7 r r r r r Z reactivexZreactivex.notificationr r r Zrecordedr Z subscriptionr
r r r. r r r/ r2 r r r r Ú s