WIP: added goroutine to catch subscribe channel output

cli/cmd/deviceSubscribe.go

@@ -63,11 +63,11 @@ The device UUID and request path must be specified as a positional arguments.`,
 				Subscription: []*pnd.Subscription{
 					{
 						Path:           args[1],
-						StreamMode:     pnd.StreamMode_STREAM_MODE_TARGET_DEFINED,
+						StreamMode:     pnd.StreamMode_STREAM_MODE_SAMPLE,
 						SampleInterval: 1000000000,
 					},
 				},
-				Mode: pnd.SubscriptionMode_SUBSCRIPTION_MODE_ONCE,
+				Mode: pnd.SubscriptionMode_SUBSCRIPTION_MODE_STREAM,
 			},
 		)
 		if err != nil {

controller/nucleus/gnmi_transport.go

@@ -198,7 +198,7 @@ func (g *Gnmi) Subscribe(ctx context.Context, params ...string) error {
 	if g.client == nil {
 		return &errors.ErrNilClient{}
 	}
-	return g.subscribe(ctx)
+	return g.subscribe2(ctx)
 }
 
 // Type returns the gNMI transport type
@@ -330,7 +330,7 @@ func (g *Gnmi) subscribe(ctx context.Context) error {
 }
 
 // Subscribe calls GNMI subscribe
-func (g *Gnmi) subscribe2(ctx context.Context, stringRespChan chan string) error {
+func (g *Gnmi) subscribe2(ctx context.Context) error {
 	ctx = gnmi.NewContext(ctx, g.config)
 	opts, ok := ctx.Value(types.CtxKeyOpts).(*gnmi.SubscribeOptions)
 	if !ok {
@@ -339,6 +339,19 @@ func (g *Gnmi) subscribe2(ctx context.Context, stringRespChan chan string) error
 			Type:  &gnmi.SubscribeOptions{},
 		}
 	}
+	stringRespChan := make(chan string)
+
+	go func() {
+		for {
+			resp := <-stringRespChan
+			if resp != "" {
+				log.Info(resp)
+			} else {
+				log.Info("recieved empty string")
+			}
+		}
+	}()
+
 	go func() {
 		log.WithFields(log.Fields{
 			"address":  opts.Target,