Struct Client 

pub struct Client {
    Sink: Arc<Mutex<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>,
    Pending: Arc<Mutex<HashMap<u64, Sender<Result<Value, String>>>>>,
    NextIdentifier: AtomicU64,
    Closed: AtomicBool,
}

Client-side connection. Holds the write half of the WebSocket and a map of pending requests keyed by id.

Fields

Sink: Arc<Mutex<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>

Pending: Arc<Mutex<HashMap<u64, Sender<Result<Value, String>>>>>

NextIdentifier: AtomicU64

Closed: AtomicBool

Implementations

impl Client

pub async fn connect(Address: &str) -> Result<Arc<Self>>

Connect to a Mist WebSocket server at Address (e.g. ws://127.0.0.1:5051). Spawns a background reader task that drains incoming frames and resolves pending requests.

pub async fn invoke(&self, Method: &str, Params: Value) -> Result<Value, String>

Invoke a remote method. Returns the result Value or an error string. Pending requests are tracked by id; on disconnect the future resolves with Err("connection closed").

pub async fn notify(&self, Method: &str, Params: Value) -> Result<(), String>

Send a one-way notification (no response expected).

pub fn is_closed(&self) -> bool