(task_pool: Runtime)
| 25 | } |
| 26 | |
| 27 | pub fn new_client(task_pool: Runtime) -> Self { |
| 28 | NativeNetResourceWrapper::Client(NativeClient::new(task_pool)) |
| 29 | } |
| 30 | |
| 31 | pub fn process_message_channel<T>(&self, channel_id: &MessageChannelID) -> Result<Vec<(ConnectionHandle, T)>, ChannelProcessingError> where T: ChannelMessage + Debug + Clone { |
| 32 | let unprocessed_messages_recv_queue = match self { |
nothing calls this directly
no outgoing calls
no test coverage detected