fix: error handling improvements

pkg/rpc/blob_datasource.go

@@ -78,8 +78,7 @@ func (ds *BlobDataSource) GetBlobs(
 			}
 		}
 	}
-	err = nil
-	return sidecars, err
+	return sidecars, nil
 }
 
 // getBlobFromServer get blob data from server path `/getBlob`.

pkg/rpc/subscription.go

@@ -124,6 +124,6 @@ func waitSubErr(ctx context.Context, sub event.Subscription) (event.Subscription
 	case err := <-sub.Err():
 		return sub, err
 	case <-ctx.Done():
-		return sub, nil
+		return sub, ctx.Err()
 	}
 }