var searchIndex = {}; searchIndex["transformable_channels"] = {"doc":"Implementation of channels that supports iterator-like operation such as `map`, `filter`\n...","items":[[0,"mpsc","transformable_channels","Near drop-in replacement for std::sync::mpsc;\nA variant of `std::sync::mpsc` that supports `map`-style operations.",null,null],[3,"Receiver","transformable_channels::mpsc","The receiving-half of Rust's channel type. This half can only be owned by\none thread",null,null],[3,"RawSender","","An implementation of `ExtSender` directly on top of `std::sync::mpsc::Sender` and with\nthe same performance.",null,null],[3,"FilterMappedSender","","An `ExtSender` obtained from a call to method `filter_map`.",null,null],[3,"FilteredSender","","An `ExtSender` obtained from a call to method `filter`.",null,null],[3,"MappedSender","","An `ExtSender` obtained from a call to method `map`.",null,null],[3,"TeedSender","","An `ExtSender` obtained from a call to method `tee`.",null,null],[5,"channel","","Creates a new asynchronous channel, returning the sender/receiver halves.\nAll data sent on the sender will become available on the receiver, and no send will block\nthe calling thread (this channel has an "infinite buffer").",null,null],[8,"ExtSender","","The sending-half of this crate's asynchronous channel type. This half can only be owned by one\nthread, but all instances can be cloned to let copies be shared with other threads.",null,null],[10,"send","","Attempts to send a value on this channel.",0,null],[10,"internal_clone","","A low-level method used to define Clone(). Probably not useful outside of this crate. May\ndisappear in future versions.",0,null],[8,"TransformableSender","","",null,null],[11,"map","","From an `ExtSender`, derive a new `ExtSender` with the same `Receiver`, but which transforms\nvalues prior to transmitting them.",1,null],[11,"filter","","From an `ExtSender`, derive a new `ExtSender` with the same `Receiver`, but which may decide\nto discard some values instead of transmitting them.",1,null],[11,"filter_map","","From an `ExtSender`, derive a new `ExtSender` with the same `Receiver`, but which may both\ntransform values priori to transmitting them, or to discard them entirely.",1,null],[11,"tee","","From two `ExtSender`s, derive a new `ExtSender` which sends to both `ExtSender`s.",1,null],[11,"send","","Let the wrapped `Sender` send the value. Discard error values.",2,null],[11,"internal_clone","","Clone the wrapped `Sender` and wrap the result.",2,null],[11,"clone","","",2,null],[11,"send","","",3,null],[11,"internal_clone","","",3,null],[11,"clone","","",3,null],[11,"send","","",4,null],[11,"internal_clone","","",4,null],[11,"clone","","",4,null],[11,"send","","",5,null],[11,"internal_clone","","",5,null],[11,"clone","","",5,null],[11,"send","","",6,null],[11,"internal_clone","","",6,null],[11,"clone","","",6,null],[11,"try_recv","","Attempts to return a pending value on this receiver without blocking",7,null],[11,"recv","","Attempts to wait for a value on this receiver, returning an error if the\ncorresponding channel has hung up.",7,null],[11,"recv_timeout","","Attempts to wait for a value on this receiver, returning an error if the\ncorresponding channel has hung up, or if it waits more than `timeout`.",7,null],[11,"iter","","Returns an iterator that will block waiting for messages, but never\n`panic!`. It will return `None` when the channel has hung up.",7,null],[11,"try_iter","","Returns an iterator that will attempt to yield all pending values.\nIt will return `None` if there are no more pending values or if the\nchannel has hung up. The iterator will never `panic!` or block the\nuser by waiting for values.",7,null],[11,"into_iter","","",7,null],[11,"drop","","",7,null],[11,"fmt","","",7,null]],"paths":[[8,"ExtSender"],[8,"TransformableSender"],[3,"RawSender"],[3,"FilterMappedSender"],[3,"FilteredSender"],[3,"MappedSender"],[3,"TeedSender"],[3,"Receiver"]]}; initSearch(searchIndex);