(request_tx: UnboundedSender<Request<V>>)
| 20 | |
| 21 | impl<V> Client<V> { |
| 22 | pub(crate) fn new(request_tx: UnboundedSender<Request<V>>) -> Self { |
| 23 | Self { request_tx } |
| 24 | } |
| 25 | |
| 26 | /// Send a request to the [`Service`], unless it has stopped listening. |
| 27 | fn send_request(&self, req: Request<V>) -> anyhow::Result<()> { |
nothing calls this directly
no outgoing calls
no test coverage detected