File tree 2 files changed +4
-4
lines changed
2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -6,7 +6,7 @@ message RPC {
6
6
7
7
message SubOpts {
8
8
optional bool subscribe = 1; // subscribe or unsubcribe
9
- optional string topicCID = 2;
9
+ optional string topicID = 2;
10
10
}
11
11
12
12
message Message {
Original file line number Diff line number Diff line change @@ -105,7 +105,7 @@ class Peer extends EventEmitter {
105
105
topics . forEach ( ( topic ) => {
106
106
subs . push ( {
107
107
subscribe : subscribe ,
108
- topicCID : topic
108
+ topicID : topic
109
109
} )
110
110
} )
111
111
@@ -153,9 +153,9 @@ class Peer extends EventEmitter {
153
153
updateSubscriptions ( changes ) {
154
154
changes . forEach ( ( subopt ) => {
155
155
if ( subopt . subscribe ) {
156
- this . topics . add ( subopt . topicCID )
156
+ this . topics . add ( subopt . topicID )
157
157
} else {
158
- this . topics . delete ( subopt . topicCID )
158
+ this . topics . delete ( subopt . topicID )
159
159
}
160
160
} )
161
161
}
You can’t perform that action at this time.
0 commit comments