RxDataSorcesに、自身を引数に取るinitをrequiredにすることで、擬似的にmutableっぽい挙動を実現させてる実装があるからワンチャン参考になるかも (edited)