🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 08:11:27 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
testing
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/testing/__pycache__
🔄 Refresh
✏️
Editing: reactivetest.cpython-38.pyc
Read Only
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 �<module> s
💾 Save Changes
❌ Cancel