File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed
gossipsub-interop/rust-libp2p/src Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -264,10 +264,15 @@ impl ScriptedNode {
264264 }
265265 }
266266 }
267- ScriptInstruction :: SubscribeToTopic { topic_id } => {
267+ ScriptInstruction :: SubscribeToTopic { topic_id, partial } => {
268268 let topic = self . get_topic ( & topic_id) ;
269269
270- match self . swarm . behaviour_mut ( ) . gossipsub . subscribe ( & topic, true ) {
270+ match self
271+ . swarm
272+ . behaviour_mut ( )
273+ . gossipsub
274+ . subscribe ( & topic, partial)
275+ {
271276 Ok ( _) => {
272277 info ! ( self . stderr_logger, "Subscribed to topic {}" , topic_id) ;
273278 }
Original file line number Diff line number Diff line change @@ -77,6 +77,7 @@ pub enum ScriptInstruction {
7777 SubscribeToTopic {
7878 #[ serde( rename = "topicID" ) ]
7979 topic_id : String ,
80+ partial : bool ,
8081 } ,
8182
8283 #[ serde( rename = "setTopicValidationDelay" , rename_all = "camelCase" ) ]
You can’t perform that action at this time.
0 commit comments