// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the Apache 2.0 License. // See the LICENSE file in the project root for more information. using System.Reactive.Subjects; namespace System.Reactive.Linq { // REVIEW: Consider if these are worth retaining in the async space. partial class AsyncObservable { public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return () => { var subject = new SequentialAsyncAsyncSubject(); try { begin(async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11, arg12) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11, arg12, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11, arg12, arg13) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11, arg12, arg13, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11, arg12, arg13, arg14) => { var subject = new SequentialAsyncAsyncSubject(); try { begin(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10, arg11, arg12, arg13, arg14, async iar => { TResult result; try { result = end(iar); } catch (Exception ex) { await subject.OnErrorAsync(ex).ConfigureAwait(false); return; } await subject.OnNextAsync(result).ConfigureAwait(false); await subject.OnCompletedAsync().ConfigureAwait(false); }, null); } catch (Exception ex) { return Throw(ex); } return subject.AsAsyncObservable(); }; } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } public static Func> FromAsyncPattern(Func begin, Func end) { if (begin == null) throw new ArgumentNullException(nameof(begin)); if (end == null) throw new ArgumentNullException(nameof(end)); return FromAsyncPattern(begin, iar => { end(iar); return Unit.Default; }); } } }