Method handleOutbound

IceFireDB-SQLProxy/pkg/p2p/pubsub.go:76–82

(ctx context.Context)

}

func (ps *PubSub) handleOutbound(ctx context.Context) {
	for msg := range ps.Outbound {
		if err := ps.Topic.Publish(ctx, []byte(msg)); err != nil {
			logrus.Errorf("Failed to publish message: %v", err)
		}
	}
}

// Exit closes the pubsub channels
func (ps *PubSub) Exit() {