U
vi&$ @ sz d dl Z d dlZd dlmZmZ d dlmZmZmZmZm Z m
Z
d dl m Z m
Z
mZmZmZ d dlmZmZ d dlmZ e ZdZdZd Zd
Zd eeeegZe eZ de ej ej eee
e e!f ef ee" eej# e
e dddZ$de ej eee
e e!f ef ee" eej# e
e dddZ%de ej ej eee
e e!f ef ee" e&ee ej ej e f dddZ'dS ) N)datetime timedelta)AnyListMappingOptionalTupleUnion) Notification
Observableabc notificationtyping)CompositeDisposable
Disposable)NewThreadSchedulerz (\(.*?\))z(-+)z(,)z(#|\||[^-,()#\|]+)|皙? )stringtimespanduetimelookuperror schedulerreturnc
s |pt }t|tr ||j }t| ||||dd}t d g d
tjt t
tj tj d fdd
}t
t tjt d fdd } |D ] }
|
\}} | | } ||| qt|S ) NT)r
time_shiftr r
raise_stoppedF)observerr r c s< s W 5 Q R X d d fdd }t|S )N)r c s8 * z W n tk
r( Y nX W 5 Q R X d S N)remove
ValueError )lockr observersr" M/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/marbles.pydisposeD s
z'hot..subscribe..dispose)appendr )r r r&
is_stoppedr# r$ )r r% subscribe; s
zhot..subscribe)r
r c s$ dt jtd d fdd
}|S )Nr stater c s6 ( D ]} | q
jdkr(d W 5 Q R X d S )N)CET)acceptkind)r r, r )r) r# r
r$ r" r% actionN s
z*hot..create_action..action)N)r
SchedulerBaser )r
r1 r( r
r%
create_actionM s
zhot..create_action)N)new_thread_scheduler
isinstancer nowparse threadingRLockr ObserverBaser r r2 DisposableBaser
r ZScheduledActionschedule_relativer )
r r r r r r
_schedulermessagesr* r4 messager
r1 r" r( r% hot! s4
"
rA )r r r r r r c sB t | |||dd dtjt ttj tjd fdd
}t|S )NT)r r r r )r
scheduler_r c sN p
|p
t t ttjtt f d d fdd }D ] }|| q<S )N)r@ r c s: | \} dt jtd d fdd
}|| d S )Nr+ c s d S r )r/ )r r, )r
r r" r% r1 z s zEfrom_marbles..subscribe..schedule_msg..action)N)r r2 r addr= )r@ r r1 r> Zdispr r3 r% schedule_msgu s z5from_marbles..subscribe..schedule_msg)r5 r r r RelativeTimer
r )r rB rE r@ r? r rD r% r* o s
z from_marbles..subscribe)N)r8 r r; r r r2 r< r )r r r r r r* r" rG r% from_marblesd s rH ?F)r r r r r r r c st |p
t d |pi t|tr&| }t|tr8| }| dd} ttttf dddtj tt
tj t t f d fdd d
td dfd d
}d}g }t
| D ]} || | | \}
} } }
|
r"|
dd d}|D ] }|| qfdd|D }|| |t|
7 }| r4|t| 7 }| rBtd|
r||
|
}|| |t|
7 }q|S )aV
Convert a marble diagram string to a list of messages.
Each character in the string will advance time by timespan
(exept for space). Characters that are not special (see the table below)
will be interpreted as a value to be emitted. numbers will be cast
to int or float.
Special characters:
+--------+--------------------------------------------------------+
| `-` | advance time by timespan |
+--------+--------------------------------------------------------+
| `#` | on_error() |
+--------+--------------------------------------------------------+
| `|` | on_completed() |
+--------+--------------------------------------------------------+
| `(` | open a group of elements sharing the same timestamp |
+--------+--------------------------------------------------------+
| `)` | close a group of elements |
+--------+--------------------------------------------------------+
| `,` | separate elements in a group |
+--------+--------------------------------------------------------+
| space | used to align multiple diagrams, does not advance time |
+--------+--------------------------------------------------------+
In a group of elements, the position of the initial `(` determines the
timestamp at which grouped elements will be emitted. E.g. `--(12,3,4)--`
will emit 12, 3, 4 at 2 * timespan and then advance virtual time
by 8 * timespan.
Examples:
>>> parse("--1--(2,3)-4--|")
>>> parse("a--b--c-", lookup={'a': 1, 'b': 2, 'c': 3})
>>> parse("a--b---#", error=ValueError("foo"))
Args:
string: String with marble diagram
timespan: [Optional] duration of each character in second.
If not specified, defaults to 0.1s.
lookup: [Optional] dict used to convert an element into a specified
value. If not specified, defaults to {}.
time_shift: [Optional] time used to delay every elements.
If not specified, defaults to 0.0s.
error: [Optional] exception that will be use in place of the # symbol.
If not specified, defaults to Exception('error').
raise_finished: [optional] raise ValueError if elements are
declared after on_completed or on_error symbol.
Returns:
A list of messages defined as a tuple of (timespan, notification).
r )elementr c S sP z
t | W S tk
rJ zt| W Y S tk
rD | Y Y S X Y nX d S r )intr! floatrL r" r" r%
try_number s
zparse..try_number)timerL r c sP |dkr| t fS |dkr*| t fS |}||}| t |fS d S )Nr #)r
Z OnCompletedZOnErrorgetZOnNext)rQ rL value)error_lookup_rP r" r% map_element s zparse..map_elementFNc s r rt d| dkr d d S )Nz2Elements cannot be declared after a # or | symbol.)rR r T)r! rO )r) r r" r%
check_stopped s
z parse..check_stoppedr ,c s g | ]}|d kr |qS )rK r" ).0elm)rW timestampr" r%
s zparse..z+Comma is only allowed in group of elements.) Exceptionr6 r
total_secondsreplacestrr rN r rF r r
r tokensfindallsplitextendlenr! r' )r r r r r r rX Ziframer? resultsgroupZticksZ comma_errorrL elementsr] Z grp_messagesr@ r" )rU r) rV rW r r^ rP r% r8 sL A
r8 )r r NNN)r NNN)rI r NNF)(rer9 r r r r r r r r r Z reactivexr
r r r
Zreactivex.disposabler r Zreactivex.schedulerr r5 Z
pattern_groupZ
pattern_ticksZpattern_comma_errorZpattern_elementjoinpatterncompilerd rc rF ZAbsoluteOrRelativeTimerN r` r2 rA rH boolr8 r" r" r" r% sv
E &