Use MultiCast with ReplaySubject to cache the last message
Swallow TaskCancelledException on write
Resolve race condition issues when subscribing for CommandReply/ApiResponse