rxrust
macro_rules! merge_subscribe { ( $op:ident, $subscriber:ident, $unsub_type: ty, $observer_creator: ident) => { ... }; }