mirror of
https://github.com/fluencelabs/registry.git
synced 2025-04-25 02:02:14 +00:00
9 lines
304 B
Plaintext
9 lines
304 B
Plaintext
|
import "@fluencelabs/aqua-dht/pubsub.aqua"
|
||
|
|
import "@fluencelabs/aqua-dht/dht.aqua"
|
||
|
|
|
||
|
|
func initTopicAndFindSubscribers(relay: string, topic: string) -> []Record:
|
||
|
|
on relay:
|
||
|
|
initTopicAndSubscribe(relay, topic, "", nil, nil)
|
||
|
|
subscribers <- findSubscribers(relay, topic)
|
||
|
|
<- subscribers
|