fixup

Author: Frando

examples/compute.rs

@@ -61,11 +61,11 @@ enum ComputeRequest {
 enum ComputeProtocol {
     #[rpc(reply=oneshot::Sender<u128>)]
     Sqr(Sqr),
-    #[rpc(request=mpsc::Receiver<i64>, reply=oneshot::Sender<i64>)]
+    #[rpc(updates=mpsc::Receiver<i64>, reply=oneshot::Sender<i64>)]
     Sum(Sum),
     #[rpc(reply=mpsc::Sender<u64>)]
     Fibonacci(Fibonacci),
-    #[rpc(request=mpsc::Receiver<u64>, reply=mpsc::Sender<u64>)]
+    #[rpc(updates=mpsc::Receiver<u64>, reply=mpsc::Sender<u64>)]
     Multiply(Multiply),
 }
 

examples/derive.rs

@@ -55,7 +55,7 @@ enum StorageProtocol {
     Get(Get),
     #[rpc(reply=oneshot::Sender<()>)]
     Set(Set),
-    #[rpc(reply=oneshot::Sender<u64>, request=mpsc::Receiver<(String, String)>)]
+    #[rpc(reply=oneshot::Sender<u64>, updates=mpsc::Receiver<(String, String)>)]
     SetMany(SetMany),
     #[rpc(reply=mpsc::Sender<String>)]
     List(List),

irpc-derive/src/lib.rs

@@ -20,7 +20,7 @@ const ATTR_NAME: &str = "rpc";
 /// the reply type name
 const TX_ATTR: &str = "reply";
 /// the request type name
-const RX_ATTR: &str = "request";
+const RX_ATTR: &str = "updates";
 /// Fully qualified path to the default request type
 const DEFAULT_RX_TYPE: &str = "::irpc::channel::none::NoReceiver";
 
@@ -161,7 +161,7 @@ fn generate_type_aliases(
 /// Individual enum variants can be annotated with the `#[rpc(...)]` attribute to specify channel types:
 ///
 /// * `#[rpc(reply=SomeType)]`: Specify the transmitter/sender channel type (required)
-/// * `#[rpc(reply=SomeType, request=OtherType)]`: Also specify a receiver channel type (optional)
+/// * `#[rpc(reply=SomeType, updates=OtherType)]`: Also specify a receiver channel type (optional)
 ///
 /// If `request` is not specified, it defaults to `NoReceiver`.
 ///

irpc-iroh/examples/auth.rs

@@ -122,7 +122,7 @@ mod storage {
         Get(Get),
         #[rpc(reply=oneshot::Sender<()>)]
         Set(Set),
-        #[rpc(reply=oneshot::Sender<u64>, request=mpsc::Receiver<(String, String)>)]
+        #[rpc(reply=oneshot::Sender<u64>, updates=mpsc::Receiver<(String, String)>)]
         SetMany(SetMany),
         #[rpc(reply=mpsc::Sender<String>)]
         List(List),