From cda59ba9c2a5e32eab71fcc9d31c583e346a57f5 Mon Sep 17 00:00:00 2001
From: neuecc <ils@neue.cc>
Date: Tue, 12 May 2020 03:41:53 +0900
Subject: [PATCH] Do

---
 src/UniTask.NetCore/Linq/Do.cs | 67 +++++++++++++++++-----------------
 1 file changed, 34 insertions(+), 33 deletions(-)

diff --git a/src/UniTask.NetCore/Linq/Do.cs b/src/UniTask.NetCore/Linq/Do.cs
index a5565fb..9cb3f41 100644
--- a/src/UniTask.NetCore/Linq/Do.cs
+++ b/src/UniTask.NetCore/Linq/Do.cs
@@ -41,47 +41,47 @@ namespace Cysharp.Threading.Tasks.Linq
             return source.Do(observer.OnNext, observer.OnError, observer.OnCompleted); // alloc delegate.
         }
 
-        // TODO:Rename -> DoAwait
+        // not yet impl.
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, Task> onNext)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwait<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, UniTask> onNext)
+        //{
+        //    throw new NotImplementedException();
+        //}
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, Task> onNext, Func<Exception, Task> onError)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwait<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, UniTask> onNext, Func<Exception, UniTask> onError)
+        //{
+        //    throw new NotImplementedException();
+        //}
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, Task> onNext, Func<Task> onCompleted)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwait<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, UniTask> onNext, Func<UniTask> onCompleted)
+        //{
+        //    throw new NotImplementedException();
+        //}
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, Task> onNext, Func<Exception, Task> onError, Func<Task> onCompleted)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwait<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, UniTask> onNext, Func<Exception, UniTask> onError, Func<UniTask> onCompleted)
+        //{
+        //    throw new NotImplementedException();
+        //}
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwaitWithCancellation<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, UniTask> onNext)
+        //{
+        //    throw new NotImplementedException();
+        //}
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext, Func<Exception, CancellationToken, Task> onError)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwaitWithCancellation<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, UniTask> onNext, Func<Exception, CancellationToken, UniTask> onError)
+        //{
+        //    throw new NotImplementedException();
+        //}
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext, Func<CancellationToken, Task> onCompleted)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwaitWithCancellation<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, UniTask> onNext, Func<CancellationToken, UniTask> onCompleted)
+        //{
+        //    throw new NotImplementedException();
+        //}
 
-        public static IUniTaskAsyncEnumerable<TSource> Do<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext, Func<Exception, CancellationToken, Task> onError, Func<CancellationToken, Task> onCompleted)
-        {
-            throw new NotImplementedException();
-        }
+        //public static IUniTaskAsyncEnumerable<TSource> DoAwaitWithCancellation<TSource>(this IUniTaskAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, UniTask> onNext, Func<Exception, CancellationToken, UniTask> onError, Func<CancellationToken, UniTask> onCompleted)
+        //{
+        //    throw new NotImplementedException();
+        //}
     }
 
     internal sealed class Do<TSource> : IUniTaskAsyncEnumerable<TSource>
@@ -252,4 +252,5 @@ namespace Cysharp.Threading.Tasks.Linq
             }
         }
     }
+
 }