# TODOs
1. Observable 的 T 和 E 用 associated type。但是rustc会卡住，等升级rustc再继续
# Check List
1. 注释
2. 文档 Example
3. 合理使用（减少不必要）
1. pub，move
2. Clone，Send, Sync, 'static
3. lock/read 等锁。 检查是否需要用Context来用一个锁？不然可能有并发问题
4. 锁的使用
1. 使用 with_mut/with_ref，或 MutableExt 的单次操作（clone_value、replace_value、
take_value）；Mutable<Option<_>> 用 take_value().map(...)，把回调放到锁外
2. 检查锁是否及时释放
1. 在 on_next 时释放context锁
2. 在 on_termination 时，释放context锁和observer锁
3. 检查锁是否应该更大范围，即一个“事务”内，只锁一次。
4. 单测
1. Cases:
1. test_completed
2. test_error
3. test_unsubscribe
4. test_ref
5. test_mut_ref
6. test_async
7. test_subscribe_by_different_observer
8. test_unsub_on_next_by_take
9. Flow（下游用 Flow::Stop 结束自己的流，源要停下来且不再 on_termination）
1. test_stop_on_next（observer 自己 stop，用 Checker::stopping_after：不再收到值，也不被
终止，被 drop）
2. Stop 经由 take 传回源：操作符和 subject 不单独写用例，而是在 test_unsub_on_next_by_take
里断言让 take 完成的那次发送答 `is_stop()`（走调度器的操作符答 `is_continue()`，值是
稍后投递的）。只有源（from_iter 等，没有 sender 可问）单独写 test_stop_on_next_by_take，
断言源停止了生产：同步源必须停下来，无限迭代器不能死循环
10. Non-creating observable
1. test_multiple_operation
2. test_without_convenient_api
11. Revertible observable
1. test_revert_completed
2. test_revert_error
12. Hot Observable (e.g. Subject, ConnectableObservable, RefCount. Only those that can borrow sender or own sender at the same time)
1. test_complete_on_next
2. test_error_on_next
3. test_unsub_on_next
4. test_sub_on_next
5. test_next_on_next
6. test_unsub_on_completed
7. test_sub_on_completed
8. test_unsub_on_error
9. test_sub_on_error
13. Using lock(with_mut|with_ref) 有的lock没 test_complete_after_next
1. test_next_on_sub
2. test_complete_on_sub
3. test_error_on_sub
4. test_sub_on_sub（另一个订阅发生在订阅过程中。只有 Hot Observable 有共享状态，冷操作符
每次订阅各有各的 context，不适用）
5. test_next_on_unsub（事件从上游自己的 disposal 里发出，即发生在退订过程中。上游直通的
操作符会把它转发给 observer，用 context 的操作符会丢弃它）
6. test_complete_on_unsub
7. test_error_on_unsub
8. test_sub_on_unsub（同 4，只有 Hot Observable 适用）
9. test_race_condition (WIP)
14. Using schedule(: Scheduler|::from_stream\\() 有的scheduler没有test_next_on_sub （如 from future）
1. ALL TESTS IN "Using lock"
2. test_complete_after_next
3. test_error_after_next
4. test_unsub_after_next
5. test_unsub_after_completed
6. test_unsub_after_error
7. test_order_with_continuous_next
8. test_no_delay (if appliable)
15. Compiling checking
1. test_lifetime
2. test_fn
3. test_clone
4. test_type_inference_with_subscribe
5. test_type_inference_without_subscribe
2. 覆盖率
# Commend
* cargo fmt
* cargo clippy --fix
* cargo tarpaulin --out Html --features tokio-scheduler
* cargo tarpaulin --out Html -- --test utils::unique_key_store
* cargo doc --open
* cargo expand