Struct SharedRunspacePool 

pub struct SharedRunspacePool<T: PsrpTransport> { /* private fields */ }

Clone-able handle to a RunspacePool.

Every method acquires an internal mutex before calling into the underlying pool, so callers can safely share a SharedRunspacePool across tasks.

Implementations

impl<T: PsrpTransport> SharedRunspacePool<T>

pub fn new(pool: RunspacePool<T>) -> Self

Wrap an already-opened RunspacePool.

pub fn handle_count(&self) -> usize

Number of outstanding handles to the same pool.

pub async fn run_script(&self, script: &str) -> Result<Vec<PsValue>>

Run a script. Acquires the mutex for the whole call.

pub async fn run_pipeline(&self, pipeline: Pipeline) -> Result<PipelineResult>

Run a pre-built Pipeline and collect every stream.

pub async fn run_script_with_cancel( &self, script: &str, cancel: CancellationToken, ) -> Result<Vec<PsValue>>

Run a script with a cancellation token.

pub async fn request_session_key(&self) -> Result<()>

Request a session key for SecureString transport.

pub async fn close(self) -> Result<()>

Close the pool. Only the last outstanding handle can actually close — if other clones are still alive, returns an error wrapping the still-contended pool.

pub async fn with_pool<F, R>(&self, f: F) -> R

where F: for<'a> FnOnce(&'a mut RunspacePool<T>) -> Pin<Box<dyn Future<Output = R> + Send + 'a>>,

Acquire the pool mutex and run a closure with direct access to the underlying RunspacePool. Useful when you need an API that isn’t surfaced on the shared wrapper.

Trait Implementations

impl<T: PsrpTransport> Clone for SharedRunspacePool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: PsrpTransport> Debug for SharedRunspacePool<T>

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

Formats the value using the given formatter.