U
vi @ sf d dl mZmZmZmZmZ d dlmZmZ edZ eee geee e f f dddZ
dgZ dS ) )CallableOptionalTupleTypeVarcast)
Observableabc_T)returnc C s$ t t t tttf ddd} | S )N)sourcer
c s6 dt jtttf tt j t jd fdd
}t|S )a3 Partially applied pairwise operator.
Returns a new observable that triggers on the second and
subsequent triggerings of the input observable. The Nth
triggering of the input observable passes the arguments from
the N-1th and Nth triggering as a pair. The argument passed to
the N-1th triggering is held in hidden internal state until the
Nth triggering occurs.
Returns:
An observable that triggers on successive pairs of
observations from the input observable as an array.
N)observer schedulerr
c s: d t td td d fdd }|jjS )NF)xr
c s> d }j r| f}nd | W 5 Q R X |r:| d S )NT)lockon_next)r pair) has_previousr previousr N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_pairwise.pyr s
z?pairwise_..pairwise..subscribe..on_next)r r subscribeZon_errorZ on_completed)r r
r r )r r r r r s
z.pairwise_..pairwise..subscribe)N)r Z ObserverBaser r r Z
SchedulerBaseZDisposableBaser )r r r r r pairwise s zpairwise_..pairwise)r r r )r r r r pairwise_ s )r N) typingr r r r r Z reactivexr r r r __all__r r r r s (-