(topic)
| 203 | return pb.ClientMsg(sub=pb.ClientSub(id=tid, topic=topic)) |
| 204 | |
| 205 | def leave(topic): |
| 206 | tid = next_id() |
| 207 | add_future(tid, { |
| 208 | 'arg': topic, |
| 209 | 'onsuccess': lambda topicName, unused: del_subscription(topicName) |
| 210 | }) |
| 211 | return pb.ClientMsg(leave=pb.ClientLeave(id=tid, topic=topic)) |
| 212 | |
| 213 | def publish(topic, text): |
| 214 | tid = next_id() |
no test coverage detected
searching dependent graphs…