refactoring

Author: giometrix

src/TableStorage.Abstractions.POCO/PocoTableStore.cs

@@ -14,7 +14,7 @@
 
 namespace TableStorage.Abstractions.POCO
 {
-	public class PocoTableStore<T, TPartitionKey, TRowKey> : IPocoTableStore<T, TPartitionKey, TRowKey> where T : new()
+	public class PocoTableStore<T, TPartitionKey, TRowKey> : IPocoTableStore<T, TPartitionKey, TRowKey> where T : class, new()
 	{
 		//hack because this is internal.  Need to get this exposed.
 		private static readonly ConcurrentDictionary<Type, ConstructorInfo> _pagedResultConstructors =
@@ -169,8 +169,7 @@ public void InsertOrReplace(T record)
 		/// <exception cref="ArgumentNullException">records</exception>
 		public void Insert(IEnumerable<T> records)
 		{
-			if (records == null)
-				throw new ArgumentNullException(nameof(records));
+			if (records == null) throw new ArgumentNullException(nameof(records));
 
 			var entities = CreateEntities(records);
 			_tableStore.Insert(entities);
@@ -353,7 +352,9 @@ public IObservable<T> GetAllRecordsObservable()
 			return Observable.Create<T>(o =>
 			{
 				foreach (var result in GetAllRecords())
+				{
 					o.OnNext(result);
+				}
 				return Disposable.Empty;
 			});
 		}
@@ -370,7 +371,9 @@ public IObservable<T> GetRecordsByFilterObservable(Func<T, bool> filter, int sta
 			return Observable.Create<T>(o =>
 			{
 				foreach (var result in GetAllRecords().Where(filter).Page(start, pageSize))
+				{
 					o.OnNext(result);
+				}
 				return Disposable.Empty;
 			});
 		}
@@ -1085,7 +1088,9 @@ private IEnumerable<DynamicTableEntity> CreateEntities(IEnumerable<T> records)
 		private T CreateRecord(DynamicTableEntity entity)
 		{
 			if (entity == null)
+			{
 				return default(T);
+			}
 
 			return _keysConverter.FromEntity(entity);
 
@@ -1110,7 +1115,9 @@ private PagedResult<T> CreatePagedResult(PagedResult<DynamicTableEntity> result,
 			var records = CreateRecords(result.Items);
 
 			if (filter != null)
+			{
 				records = records.Where(filter);
+			}
 
 			return ctor.Invoke(new object[]
 				{records.ToList(), result.ContinuationToken, result.IsFinalPage}) as PagedResult<T>;