Searched refs:rpc_looper (Results 1 – 4 of 4) sorted by relevance
/dports/editors/xi-core/xi-editor-0.3.0/rust/core-lib/tests/ |
H A D | rpc.rs | 33 let mut rpc_looper = RpcLoop::new(tx); in test_startup() localVariable 65 let mut rpc_looper = RpcLoop::new(write); in test_state() localVariable 66 rpc_looper.mainloop(|| json, &mut state).unwrap(); in test_state() 75 rpc_looper.mainloop(|| json, &mut state).unwrap(); in test_state() 88 rpc_looper.mainloop(|| json, &mut state).unwrap(); in test_state() 101 let mut rpc_looper = RpcLoop::new(write); in test_malformed_json() localVariable 127 let mut rpc_looper = RpcLoop::new(write); in test_movement_cmds() localVariable 137 rpc_looper.mainloop(|| json, &mut state).unwrap(); in test_movement_cmds() 146 let mut rpc_looper = RpcLoop::new(write); in test_text_commands() localVariable 163 let mut rpc_looper = RpcLoop::new(write); in test_other_edit_commands() localVariable [all …]
|
/dports/editors/xi-core/xi-editor-0.3.0/rust/rpc/tests/ |
H A D | integration.rs | 43 let mut rpc_looper = RpcLoop::new(tx); in test_recv_notif() localVariable 45 assert!(rpc_looper.mainloop(|| r, &mut handler).is_ok()); in test_recv_notif() 55 let mut rpc_looper = RpcLoop::new(tx); in test_recv_resp() localVariable 57 assert!(rpc_looper.mainloop(|| r, &mut handler).is_ok()); in test_recv_resp() 62 assert!(rpc_looper.mainloop(|| r, &mut handler).is_ok()); in test_recv_resp() 72 let mut rpc_looper = RpcLoop::new(tx); in test_recv_error() localVariable 75 assert!(rpc_looper.mainloop(|| r, &mut handler).is_ok()); in test_recv_error() 84 let mut rpc_looper = RpcLoop::new(io::sink()); in test_bad_json_err() localVariable 86 let exit = rpc_looper.mainloop(|| r, &mut handler); in test_bad_json_err()
|
/dports/editors/xi-core/xi-editor-0.3.0/rust/plugin-lib/src/ |
H A D | lib.rs | 208 let mut rpc_looper = RpcLoop::new(stdout); in mainloop() localVariable 211 rpc_looper.mainloop(|| stdin.lock(), &mut dispatcher) in mainloop()
|
/dports/editors/xi-core/xi-editor-0.3.0/rust/src/ |
H A D | main.rs | 211 let mut rpc_looper = RpcLoop::new(stdout); in main() localVariable 229 match rpc_looper.mainloop(|| stdin.lock(), &mut state) { in main()
|