🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:16:40 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _sequenceequal.cpython-38.pyc
Read Only
U v�i4 � @ s� d dl mZmZmZmZmZmZ d dlZd dlmZm Z m Z d dl m Z d dl m Z ed�Zd eee ee f ee je eee gee f d�dd �Zd gZdS ) � )�Callable�Iterable�List�Optional�TypeVar�UnionN)� Observable�abc�typing)�CompositeDisposable)�default_comparer�_T)�second�comparer�returnc sB |pt � t| t�r t�| �n| �tt tt d�� �fdd� }|S )N)�sourcer c s2 | � dt jt tt j d��� �fdd� }t|�S )a< Determines whether two sequences are equal by comparing the elements pairwise using a specified equality comparer. Examples: >>> res = sequence_equal([1,2,3]) >>> res = sequence_equal([{ "value": 42 }], lambda x, y: x.value == y.value) >>> res = sequence_equal(reactivex.return_value(42)) >>> res = sequence_equal( reactivex.return_value({ "value": 42 }), lambda x, y: x.value == y.value ) Args: source: Source observable to compare. Returns: An observable sequence that contains a single element which indicates whether both sequences are of equal length and their corresponding elements are equal according to the specified equality comparer. N)�observer� schedulerc s� dg� dg�g �g �t d d������fdd� }d d�� ����fdd� }t d��� ���fd d � }� ����fd d �}�j|�j||d �}�j|�j||d �}t||�S )NF)�xr c s� t ��dkrp��d�}z� || �}W n2 tk rV } z��|� W Y �d S d }~X Y nX |s���d� ��� n&�d r���d� ��� n ��| � d S �Nr F��len�pop� Exception�on_error�on_next� on_completed�append)r �v�equal�e)� comparer_�donerr �ql�qr� �S/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_sequenceequal.py�on_next15 s zLsequence_equal_.<locals>.sequence_equal.<locals>.subscribe.<locals>.on_next1)r c sB d� d< �s>�r$�� d� ��� n�d r>�� d� ��� d S �NTr F)r r r% ��donelr" r r# r$ r% r& � on_completed1H s zQsequence_equal_.<locals>.sequence_equal.<locals>.subscribe.<locals>.on_completed1)r c s� t ��dkrp��d�}z� || �}W n2 tk rV } z��|� W Y �d S d }~X Y nX |s���d� ��� n&�d r���d� ��� n ��| � d S r r )r r r � exception)r! r* r r# r$ r% r& �on_next2R s zLsequence_equal_.<locals>.sequence_equal.<locals>.subscribe.<locals>.on_next2c sJ d�d< �sFt ��dkr,��d� ��� n� d rF��d� ��� d S r( )r r r r% r) r% r& � on_completed2e s zQsequence_equal_.<locals>.sequence_equal.<locals>.subscribe.<locals>.on_completed2)r )r � subscriber r )r r r' r+ r- r. Z subscription1Z subscription2)r! �first�second_r) r& r/ , s* � �z:sequence_equal_.<locals>.sequence_equal.<locals>.subscribe)N)r Z ObserverBase�boolr Z SchedulerBaser )r r/ �r! r1 )r0 r& �sequence_equal s ��Kz'sequence_equal_.<locals>.sequence_equal)r � isinstancer � reactivex� from_iterabler r r2 )r r r4 r% r3 r& �sequence_equal_ s � er8 )N)r r r r r r r r6 r r Zreactivex.disposabler Zreactivex.internalr r ZComparerr2 r8 �__all__r% r% r% r& �<module> s � � q
💾 Save Changes
❌ Cancel