pub fn store_shared<K>(buf_size: usize) -> (Store<K>, Writer<K>)
Expand description
Create a (Reader, Writer) for a Store<K>
for a typed resource K
The resulting Writer
can be subscribed on in order to fan out events from
a watcher. The Writer
should be passed to a reflector
,
and the Store
is a read-only handle.
A buffer size is used for the underlying message channel. When the buffer is full, backpressure will be applied by waiting for capacity.