(topic, text)
| 211 | return pb.ClientMsg(leave=pb.ClientLeave(id=tid, topic=topic)) |
| 212 | |
| 213 | def publish(topic, text): |
| 214 | tid = next_id() |
| 215 | return pb.ClientMsg(pub=pb.ClientPub(id=tid, topic=topic, no_echo=True, |
| 216 | head={"auto": json.dumps(True).encode('utf-8')}, content=json.dumps(text).encode('utf-8'))) |
| 217 | |
| 218 | def note_read(topic, seq): |
| 219 | return pb.ClientMsg(note=pb.ClientNote(topic=topic, what=pb.READ, seq_id=seq)) |
no test coverage detected
searching dependent graphs…