INNER CODE UNIT · Go

doSubscribe

kluctl/kluctl · internal/ipfs-exchange-info/main.go:255

func doSubscribe(ctx context.Context, h host.Host, discovery *drouting.RoutingDiscovery) error {
	doneCh := make(chan bool)
	h.SetStreamHandler("/x/kluctl-preview-info", func(s network.Stream) {
		defer s.Close()

		enc := gob.NewEncoder(s)
		dec := gob.NewDecoder(s)

		var b []byte
		err := dec.Decode(&b)
		if err != nil {
			log.Infof("Receive failed: %v", err)
			return
		}

		err = handleInfo(ctx, b)
		isDone := err == nil
		if err != nil {

View source record →