rpc module: add call_and_subscribe

types/src/v2/request.rs

@@ -50,7 +50,7 @@ pub struct Request<'a> {
 }
 
 impl<'a> Request<'a> {
-	/// Create a new `Request`.
+	/// Create a new [`Request`].
 	pub fn new(method: Cow<'a, str>, params: Option<&'a RawValue>, id: Id<'a>) -> Self {
 		Self { jsonrpc: TwoPointZero, id, method, params }
 	}
@@ -79,7 +79,7 @@ pub struct Notification<'a, T> {
 }
 
 impl<'a, T> Notification<'a, T> {
-	/// Create a new `Notification`.
+	/// Create a new [`Notification`].
 	pub fn new(method: Cow<'a, str>, params: T) -> Self {
 		Self { jsonrpc: TwoPointZero, method, params }
 	}

types/src/v2/response.rs

@@ -46,7 +46,7 @@ pub struct Response<'a, T> {
 }
 
 impl<'a, T> Response<'a, T> {
-	/// Create a new `Response`.
+	/// Create a new [`Response`].
 	pub fn new(result: T, id: Id<'a>) -> Response<'a, T> {
 		Response { jsonrpc: TwoPointZero, result, id }
 	}

utils/src/server/rpc_module.rs

@@ -369,10 +369,18 @@ impl Methods {
 		rx.next().await
 	}
 
-	/// Perform a method call and receive further subscriptions.
+	/// Perform a "in memory JSON-RPC method call" and receive further subscriptions.
+	/// This is useful if you want to support both `method calls` and `subscriptions`
+	/// in the same API.
 	///
-	/// Returns a response to actual method call and a stream to process
-	/// futher subscriptions if a subcription was registered on the call.
+	/// There are better variants than this method if you only want
+	/// method calls or subscriptions.
+	///
+	/// See [`Methods::test_subscription`] and [`Methods::call_with`] for
+	/// for further documentation.
+	///
+	/// Returns a response to the actual method call and a stream to process
+	/// further notifications if a subscription was registered by the call.
 	///
 	/// ```
 	/// #[tokio::main]
@@ -386,7 +394,7 @@ impl Methods {
 	///
 	///     let mut module = RpcModule::new(());
 	///     module.register_subscription("hi", "hi", "goodbye", |_, mut sink, _| {
-	///     sink.send(&"one answer").unwrap();
+	///         sink.send(&"one answer").unwrap();
 	///         Ok(())
 	///     }).unwrap();
 	///     let (resp, mut stream) = module.call_and_subscribe("hi", EmptyParams::new()).await.unwrap();