Method Subscribe

pkg/component/grpc_test.go:49–61

(id *ttnpb.ApplicationIdentifiers, stream ttnpb.AppAs_SubscribeServer)

}

func (as *asImplementation) Subscribe(id *ttnpb.ApplicationIdentifiers, stream ttnpb.AppAs_SubscribeServer) error {
	if err := clusterauth.Authorized(stream.Context()); err != nil {
		return err
	}
	for {
		select {
		case <-stream.Context().Done():
			return nil
		case up := <-as.up:
			stream.Send(up)
		}
	}
}

type gsImplementation struct {
	ttnpb.UnimplementedGsServer