5ef7439d71
interface: New Topic + TopicEventHandlers objects.
...
Added PubSub.Join(topic) that returns a Topic object. This object can be Subscribed and Published to as well as to get a TopicEventHandler for topic events. This means that the Subscription object will no longer handle PeerEvents and that PubSub's Publish and Subscribe functions are deprecated.
2019-10-31 15:37:44 -04:00
9d03237eec
add PubSub's context to Subscription
2019-09-30 12:55:37 +03:00
97e63e477e
better context respect when waiting for new peer events. refactored backlog into eventLog. removed test that was no longer useful.
2019-08-06 00:26:40 -04:00
65825ce63a
fix race
2019-08-05 15:48:31 -04:00
57f2c1efdd
Refactored events to be camel case.
2019-08-02 12:25:57 -04:00
48c9847240
oops forgot a return. separated out and added more comments to the new tests.
2019-08-02 00:46:49 -04:00
934b813b9a
stronger notification deliveries backed by unbounded buffer
2019-08-01 16:57:05 -04:00
e4a65bcf1c
Made discovery enum use int and removed the UNKNOWN zero value from the enum
2019-07-22 10:02:58 -04:00
ae667299a8
go fmt
2019-07-01 17:43:49 +02:00
e26e489bdd
Small code cleanup + refactor
2019-06-21 08:46:41 +02:00
be69856a1d
Fixed some unnecessary Leave notifications.
...
Combined Join and Leave events into a single API with a struct that specifies whether the event is a Join or a Leave.
2019-06-12 10:06:16 -04:00
817651a6d1
Subscription Join events now fire even for peers connected to us before we subscribe.
...
Added a Subscription Leave event
2019-06-11 17:49:28 -04:00
8037a2e60f
Add the ability to handle newly subscribed peers
2019-06-07 08:31:14 -04:00
bd1a4630b9
move to go-libp2p-pubsub
...
Updates for move from go-floodsub to go-libp2p-pubsub.
fixes https://github.com/libp2p/go-libp2p-pubsub/issues/4
2018-10-18 21:10:16 +01:00
25b8aad61f
add ctx to sub.Next for cancellation
2016-11-18 02:23:38 +01:00
822640a482
multiple subscriptions prototype
2016-11-18 02:23:38 +01:00
Adin Schmahmann
lukesolo
Steven Allen
Jan Winkelmann