var searchIndex = {};
searchIndex["capnp_nonblock"] = {"doc":"`capnp_nonblock` provides a helper struct, `MessageStream`, for reading and\nwriting [Cap'n Proto](https://capnproto.org/) messages to non-blocking\nstreams.","items":[[3,"Segments","capnp_nonblock","A Cap'n Proto message container.",null,null],[3,"MessageStream","","A `MessageStream` wraps a stream, and provides methods to read and write\nCap'n Proto messages to the stream. `MessageStream` performs its own\ninternal buffering, so the provided stream need not be buffered.",null,null],[11,"get_segment","","",0,null],[11,"new","","Creates a new `MessageStream` instance wrapping the provided stream, and\nwith the provided reader options.",1,{"inputs":[{"name":"s"},{"name":"readeroptions"}],"output":{"name":"messagestream"}}],[11,"outbound_queue_len","","Returns the number of queued outbound messages.",1,null],[11,"clear_outbound_queue","","Clears the outbound message queue of all messages that have not begun\nwriting yet.",1,null],[11,"inner_mut","","Returns the inner stream.",1,null],[11,"inner","","Returns the inner stream.",1,null],[11,"read_message","","Returns the next message from the stream, or `None` if the entire\nmessage is not yet available.",1,null],[11,"fmt","","",1,null],[11,"write","","Writes queued messages to the stream. This should be called when the\nstream is in non-blocking mode and writable.",1,null],[11,"write_message","","Queue message for write.",1,null]],"paths":[[3,"Segments"],[3,"MessageStream"]]};
initSearch(searchIndex);