úÎŒ*…aW      !"#$%&'()*+,- . / 0 1 2 3 4 5 6 7 8 9 : ; < = > ? @ A B C D E F G H I J K L M N O P Q R S T U V Safe.Represents an event that a signal might send. Signals may send any number of s, followed by one  or . CSent when the signal completes successfully. Outside of the monad. LSent when an error or exception occurs in the signal. Outside of the monad. A value v in the monad. WXWXSafe #A synchronized set of disposables. YJust s when not yet disposed. Nothing after disposal. @Allows disposal of a resource by running an action in the monad m. Disposes a disposable. @Creates a disposable which runs the given action upon disposal. Creates a set of disposables. 1Converts a set of disposables into a disposable. J The constructed disposable will dispose of all disposables in the set. Adds a disposable to a set. !Removes a disposable from a set. ZY[ \   ZY[ \Safe JA scheduler which runs enqueued actions in a dedicated background thread. Represents a queue of ]. actions which can be executed in FIFO order. [Schedules an action on the scheduler. Returns a disposable which can be used to cancel it. IExecutes all current and future actions enqueued on the given scheduler. aRepresents an action on a scheduler, along with a flag indicating whether it should be canceled. An ]; computation that must be performed in a scheduler of type s. =Returns the scheduler that the calling code is executing on. YCreates a new scheduled action, and returns a disposable which can be used to cancel it. *Executes the given action, then re-enters .  ^_`abc    ^_`abcSafe$Creates a new background scheduler.    Trustworthy<A scheduler which runs enqueued actions on the main thread. 2Returns a scheduler representing the main thread.  Note that : must be called for enqueued actions to actually execute. ?Runs the main scheduler indefinitely using the current thread. 1 The current thread will be bound if possible. defdefUnsafegExtracts the underlying ] action from a  action. YThis can be unsafe because the type system does not have enough information to determine D whether the calling code is running on an appropriate scheduler. hUnsafely executes a  action and shows the result.  This is for DEBUGGING PURPOSES ONLY. gihgihSafe2Receives events from a signal with values of type v$ and running in a scheduler of type s.  Note that sM refers to the scheduler that events must be sent on. Events are always sent  synchronously, regardless of s. #AAdds a disposable representing a subscription to the subscriber. X If the subscriber is later sent completed or error, the disposable will be disposed. $FDisposes the subscriber, preventing it from receiving any new events.  !"#$  !"#$  !"#$ !"#$Safe%Constructs a subscriber. j0Acquires a subscriber for the specified thread. VThis is used to ensure that a subscriber never receives multiple events concurrently. k/Releases a subscriber from the specified thread' s ownership. #This must match a previous call to j. &.Synchronously sends an event to a subscriber. %.An action to run when each event is received. The constructed subscriber. jk&%&%&%jk&Safe'(A signal which will send values of type v on a scheduler of type s. (MConstructs a signal which sends its values to new subscribers synchronously. )Subscribes to a signal. */Returns a signal which never sends any events. +.Returns a signal which immediately completes. ,3Creates a subscriber and subscribes to the signal. 'l('An action to run on each subscription. The constructed signal. )The signal to subscribe to. The subscriber to attach. >A disposable which can be used to terminate the subscription. *+,The signal to subscribe to. .An action to run when each event is received. >A disposable which can be used to terminate the subscription. mnopqrs '()*+, '(),*+ 'l()*+,mnopqrs Safe-7Determines how many events a replay channel will save. .5The channel will save an unlimited number of events. /;The channel will only save the specified number of events. 0(A controllable signal, represented by a  and ' pair. RValues sent to the subscriber will automatically be broadcast to all of the signal's subscribers. Q In effect, the subscriber is the write end, while the signal is the read end. 1ACreates a simple channel which broadcasts all values sent to it.  Sending an  or  will terminate the channel. 2Like 1G, but new subscriptions to the returned signal will receive all values A (up to the specified capacity) which have been sent thus far.  Sending an  or 3 will terminate the channel. Any terminating event I will be replayed to future subscribers, assuming sufficient capacity. -./012 '-./012 01-/.2'-/.012 Safe3]Multicasts a signal to many subscribers, without triggering any side effects more than once. 4CCreates a connection that will subscribe to the given base signal, 2 and forward all events onto the given channel. 5 Multicasts to a simple channel. tUMulticasts to a replay channel of the specified capacity, then connects immediately. 6QMulticasts to a replay channel of unlimited capacity, then connects immediately. 7IMulticasts to a replay channel of capacity 1, then connects immediately. 80Returns the multicasted signal of a connection. 5No events will be sent on the resulting signal until 9 is invoked. 9@Activates a connection by subscribing to its underlying signal. N Calling this function multiple times just returns the existing disposable. 3uvwxy45t6789 '03456789 34598670'3uvwxy45t6789 Safe: Turns any z into a signal. ;/Brings every signal event into the monad, as a  containing the event itself. <The inverse of ;. =9Filters the values of a signal according to a predicate. >ARuns a side-effecting action whenever the signal sends an event. ?@Runs a side-effecting action whenever the signal sends a value. @ARuns a side-effecting action whenever the signal sends an error. A8Runs a side-effecting action when the signal completes. BBRuns a side-effecting action when the signal completes or errors. CReturns a signal of the first n elements. D#Returns a signal without the first n elements. E#Returns a signal of mapped values. FKReturns a signal that sends the values from the most recently sent signal. G1Combines the latest values sent by both signals. :;<=>?@ABCDEFG'*+:;<=>?@ABCDEFG>?@AB;<:E=CDFG*+':;<=>?@ABCDEFG SafeHStarts a signal which executes action on s. I%Returns a signal which subscribes to sig on scheduler sch. J%Returns a signal which subscribes to sig on scheduler schA( and delivers its events onto scheduler schB. KSubscribes to sig' and synchronously waits for an event. HIJK'HIJKHIJK'HIJK Safe LEA signal triggered in response to some action, typically UI-related. MDetermines a command' s behavior. N>The command can be executed concurrently any number of times. O1The command can only be executed once at a time.  Attempts to U1 while the command is already running will fail. PCreates a command. Q3Sends whether this command is currently executing. OThis signal will always send at least one value immediately upon subscription. R8A signal of errors received from all signals created by V. S!A signal of the values passed to U. T/Sends whether this command is able to execute. OThis signal will always send at least one value immediately upon subscription. {Sends a new value for Q. UAttempts to execute a command. VGCreates a signal whenever the command executes, then subscribes to it. L|}~€‚MNOP1Determines how the command behaves when asked to U multiple times simultaneously. <A signal which sends whether the command should be enabled.  T will send ƒ+ before this signal sends its first value. QRST{UThe command to execute. A value to send to the command's subscribers. *Whether execution succeeded. This will be „ if the command is disabled. V#The command to attach behavior to. &A function which maps from the command'-s values to a signal of side-effecting work. !A signal of the created signals.  '0LMNOPQRSTUVLMONPTQUSVR0'  L|}~€‚MONPQRST{UV… !"#$%&''()*+,-./012345 6 7 8 9 : ; < = > ? @ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z [ \ ] ^ _`abcdefghijk$lmnopqrstuvwxy z < { | } ~€ ‚ U ƒ „ … † ‡ ˆde‰deŠ‹ RxHaskell-0.2 Signal.Event DisposableScheduler.Internal SchedulerScheduler.MainSignal.Subscriber.InternalSignal.SubscriberSignalSignal.ChannelSignal.ConnectionSignal.OperatorsSignal.ScheduledSignal.CommandScheduler.UnsafeEventCompletedEvent ErrorEvent NextEvent DisposableSetEmptyDisposabledispose newDisposablenewDisposableSet toDisposable addDisposableremoveDisposableBackgroundSchedulerschedule schedulerMainScheduledAction SchedulerIOgetCurrentSchedulernewScheduledActionexecuteScheduledAction newScheduler MainSchedulergetMainSchedulerrunMainScheduler SubscriberonEvent disposables lockedThreadthreadLockCounterdisposedaddSubscriptionDisposabledisposeSubscriber subscribersendsignal subscribeneverempty>>:ChannelCapacityUnlimitedCapacityLimitedCapacityChannel newChannelnewReplayChannel Connection multicastpublishreplay replayLastmulticastedSignalconnect fromFoldable materialize dematerializefilterdoEventdoNextdoError doCompletedfinallytakedropmapswitchcombinestart subscribeOn deliverOnfirstCommand CommandPolicyExecuteConcurrentlyExecuteSerially newCommand executingerrorsvalues canExecuteexecute onExecute $fShowEvent $fEqEventMaybeSet$fEqDisposableghc-prim GHC.TypesIO$fSchedulerBackgroundScheduler$fApplicativeSchedulerIO$fMonadIOSchedulerIO$fMonadSchedulerIO$fFunctorSchedulerIOmainSchedulerRef$fSchedulerMainSchedulerunsafeRunSchedulerIO$fShowSchedulerIO0$fShowSchedulerIOacquireSubscriberreleaseSubscriberszip$fMonadZipSignal$fMonadPlusSignal$fMonoidSignal$fApplicativeSignal$fFunctorSignal $fMonadSignalreplayCapacity baseSignal disposablechannel hasConnectedbase Data.FoldableFoldable setExecutingpolicy valuesChannel errorsChannel itemsInFlightexecutingChannelcanExecuteChannelTrueFalse