internal

Oct 3, 2023

Changes in this version

+ type ReadSubscription struct

+ func NewReadSubscription(sub p2p.Subscription, callback ReadSubscriptionCallBackFunction, ...) *ReadSubscription

+ func (r *ReadSubscription) ReceiveLoop(ctx context.Context)

+ type ReadSubscriptionCallBackFunction func(msg *message.Message, peerID peer.ID)