Source

core hello world / broker_protocol.ml

Diff from to

broker_protocol.ml

   ~version:0
   ~bin_query:Unit.bin_t
   ~bin_response:Unit.bin_t
+
+let clear_rpc = Rpc.Rpc.create
+  ~name:"clear"
+  ~version:0
+  ~bin_query:Topic.bin_t
+  ~bin_response:Unit.bin_t