var searchIndex = {}; searchIndex["rx"] = {"doc":"Rx, a library for reactive programming in Rust.\nInspired by [Reactive Extensions for C#](https://rx.codeplex.com/).","items":[[3,"Subject","rx","Both an observer and observable.",null,null],[3,"UncancellableSubscription","","A subscription where `drop()` is a no-op.",null,null],[11,"new","","Creates a new subject.",0,{"inputs":[],"output":{"name":"subject"}}],[11,"on_next","","",0,null],[11,"on_completed","","",0,null],[11,"on_error","","",0,null],[8,"Observable","","A stream of values.",null,null],[16,"Item","","The value produced by the observable.",1,null],[16,"Error","","The error produced if the observable fails.",1,null],[16,"Subscription","","The result of subscribing an observer.",1,null],[10,"subscribe","","Subscribes an observer and returns the subscription.",1,null],[11,"subscribe_next","","Subscribes a function to handle values produced by the observable.",1,null],[11,"subscribe_completed","","Subscribes functions to handle next and completion.",1,null],[11,"subscribe_error","","Subscribes functions to handle next, completion, and error.",1,null],[11,"subscribe_option","","Subscribes a function that takes an option.",1,null],[11,"subscribe_result","","Subscribes a function that takes a result of an option.",1,null],[8,"Observer","","An observer that receives values from an observable.",null,null],[10,"on_next","","Provides the observer with new data.",2,null],[10,"on_completed","","Notifies the observer that the provider has finished sending notifications.",2,null],[10,"on_error","","Notifies the observer that the provider experienced an error condition.",2,null],[11,"drop","","",3,null],[11,"subscribe_next","","Subscribes a function to handle values produced by the observable.",1,null],[11,"subscribe_completed","","Subscribes functions to handle next and completion.",1,null],[11,"subscribe_error","","Subscribes functions to handle next, completion, and error.",1,null],[11,"subscribe_option","","Subscribes a function that takes an option.",1,null],[11,"subscribe_result","","Subscribes a function that takes a result of an option.",1,null]],"paths":[[3,"Subject"],[8,"Observable"],[8,"Observer"],[3,"UncancellableSubscription"]]}; initSearch(searchIndex);