(
writer: &mut W,
connection_id: &str,
app_id: &str,
page_id: u64,
sender_id: &str,
)
| 897 | } |
| 898 | |
| 899 | async fn send_forward_socket_setup<W: AsyncWrite + Unpin>( |
| 900 | writer: &mut W, |
| 901 | connection_id: &str, |
| 902 | app_id: &str, |
| 903 | page_id: u64, |
| 904 | sender_id: &str, |
| 905 | ) -> Result<(), AppError> { |
| 906 | let mut args = rpc_args(connection_id); |
| 907 | args.insert( |
| 908 | "WIRApplicationIdentifierKey".to_owned(), |
| 909 | Value::String(app_id.to_owned()), |
| 910 | ); |
| 911 | args.insert("WIRAutomaticallyPause".to_owned(), Value::Boolean(false)); |
| 912 | args.insert( |
| 913 | "WIRPageIdentifierKey".to_owned(), |
| 914 | Value::Integer(page_id.into()), |
| 915 | ); |
| 916 | args.insert( |
| 917 | "WIRSenderKey".to_owned(), |
| 918 | Value::String(sender_id.to_owned()), |
| 919 | ); |
| 920 | send_rpc(writer, "_rpc_forwardSocketSetup:", args).await |
| 921 | } |
| 922 | |
| 923 | async fn send_forward_socket_data<W: AsyncWrite + Unpin>( |
| 924 | writer: &mut W, |
no test coverage detected