Adding to the Rid object introduced with the last change, to expose the following:
rid.debugReply controls how/if replies to requests are logged (was RID_DEBUG_REPLY), has
a default
rid.debugLock controls how/if locking the store on access is logged (was RID_DEBUG_LOCK)
has a default
rid.replyTimeoutconfigures the Duration after which a missing reply for a request mesage
sent via the rid.replyChannel results in an error (was RID_REPLY_TIMEOUT), has a default
rid.replyChannel provides access the channel over which replies to requests are sent,
namely the Stream<TReply>rid.replyChannel.stream which can be used to subscribe to those
replies (was replyChannel)
rid.messageChannel provides access to messages sent to Dart from Rust, i.e. via
rid::log_debug! or rid::error! macros, namely the Stream<RidMessage> rid.messageChannel.stream which can be used to subscribe to those messages, by default those
messages aren't handled
Tests and examples here were updated to this API update and I will provide a related PR in
order to adapt them as well.
Adding to the Rid object introduced with the last change, to expose the following:
rid.debugReplycontrols how/if replies to requests are logged (wasRID_DEBUG_REPLY), has a defaultrid.debugLockcontrols how/if locking the store on access is logged (wasRID_DEBUG_LOCK) has a defaultrid.replyTimeoutconfigures theDurationafter which a missing reply for a request mesage sent via therid.replyChannelresults in an error (wasRID_REPLY_TIMEOUT), has a defaultrid.replyChannelprovides access the channel over which replies to requests are sent, namely theStream<TReply>rid.replyChannel.streamwhich can be used to subscribe to those replies (wasreplyChannel)rid.messageChannelprovides access to messages sent to Dart from Rust, i.e. viarid::log_debug!orrid::error!macros, namely theStream<RidMessage> rid.messageChannel.streamwhich can be used to subscribe to those messages, by default those messages aren't handledTests and examples here were updated to this API update and I will provide a related PR in order to adapt them as well.