Struct OutgoingRequests 

pub struct OutgoingRequests<O> { /* private fields */ }

Tracks requests sent to clients (outgoing from the server).

When the server sends a request to the client, it registers the request ID and receives a oneshot receiver. When the client’s response arrives, the server completes the request, sending the response to the waiting receiver.

The generic parameter O represents the response type that will be delivered when the request completes.

Example

use lsp_server_tokio::{OutgoingRequests, RequestId};

let mut outgoing: OutgoingRequests<String> = OutgoingRequests::new();

// Register an outgoing request
let rx = outgoing.register(1.into());
assert!(outgoing.is_pending(&1.into()));

// Simulate receiving a response
let completed = outgoing.complete(&1.into(), "result".to_string());
assert!(completed);

// Receiver gets the response
let result = rx.await.unwrap();
assert_eq!(result, "result");

Implementations

impl<O> OutgoingRequests<O>

pub fn new() -> Self

Creates a new empty outgoing request tracker.

pub fn register(&mut self, id: RequestId) -> Receiver<O>

Registers an outgoing request and returns a receiver for the response.

The returned receiver will receive the response value when complete is called with a matching ID. If the request is cancelled via cancel, the receiver will return a RecvError.

pub fn complete(&mut self, id: &RequestId, response: O) -> bool

Completes an outgoing request by sending the response to the waiting receiver.

Returns true if the request was pending and the response was sent, false if the request was not found.

Note: This returns true even if the receiver was dropped (the response is still considered “completed” from the queue’s perspective).

pub fn cancel(&mut self, id: &RequestId) -> bool

Cancels an outgoing request without sending a response.

The sender is dropped, causing the receiver to return RecvError.

Returns true if the request was pending, false otherwise.

pub fn is_pending(&self, id: &RequestId) -> bool

Returns true if the request is currently pending.

pub fn pending_count(&self) -> usize

Returns the number of currently pending requests.

Trait Implementations

impl<O: Debug> Debug for OutgoingRequests<O>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<O> Default for OutgoingRequests<O>

fn default() -> Self

Returns the “default value” for a type.