OpenTween/Extensions.cs

   1 // OpenTween - Client of Twitter
   2 // Copyright (c) 2015 kim_upsilon (@kim_upsilon) <https://upsilo.net/~upsilon/>
   3 // All rights reserved.
   4 //
   5 // This file is part of OpenTween.
   6 //
   7 // This program is free software; you can redistribute it and/or modify it
   8 // under the terms of the GNU General Public License as published by the Free
   9 // Software Foundation; either version 3 of the License, or (at your option)
  10 // any later version.
  11 //
  12 // This program is distributed in the hope that it will be useful, but
  13 // WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
  14 // or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
  15 // for more details.
  16 //
  17 // You should have received a copy of the GNU General Public License along
  18 // with this program. If not, see <http://www.gnu.org/licenses/>, or write to
  19 // the Free Software Foundation, Inc., 51 Franklin Street - Fifth Floor,
  20 // Boston, MA 02110-1301, USA.
  21
  22 using System;
  23 using System.Collections.Generic;
  24 using System.Globalization;
  25 using System.Linq;
  26 using System.Text;
  27 using System.Threading;
  28 using System.Threading.Tasks;
  29 using System.Windows.Forms;
  30
  31 namespace OpenTween
  32 {
  33     internal static class Extensions
  34     {
  35         /// <summary>
  36         /// WebBrowserで選択中のテキストを取得します
  37         /// </summary>
  38         public static string GetSelectedText(this WebBrowser webBrowser)
  39         {
  40             dynamic document = webBrowser.Document.DomDocument;
  41             dynamic textRange = document.selection.createRange();
  42             string selectedText = textRange.text;
  43
  44             return selectedText;
  45         }
  46
  47         public static ReadLockTransaction BeginReadTransaction(this ReaderWriterLockSlim lockObj)
  48             => new ReadLockTransaction(lockObj);
  49
  50         public static WriteLockTransaction BeginWriteTransaction(this ReaderWriterLockSlim lockObj)
  51             => new WriteLockTransaction(lockObj);
  52
  53         public static UpgradeableReadLockTransaction BeginUpgradeableReadTransaction(this ReaderWriterLockSlim lockObj)
  54             => new UpgradeableReadLockTransaction(lockObj);
  55
  56         /// <summary>
  57         /// 一方のカルチャがもう一方のカルチャを内包するかを判断します
  58         /// </summary>
  59         public static bool Contains(this CultureInfo @this, CultureInfo that)
  60         {
  61             if (@this.Equals(that))
  62                 return true;
  63
  64             // InvariantCulture の親カルチャは InvariantCulture 自身であるため、false になったら打ち切る
  65             if (!that.Parent.Equals(that))
  66                 return Contains(@this, that.Parent);
  67
  68             return false;
  69         }
  70
  71         public static void Deconstruct<TKey, TValue>(this KeyValuePair<TKey, TValue> kvp, out TKey key, out TValue value)
  72         {
  73             key = kvp.Key;
  74             value = kvp.Value;
  75         }
  76
  77         /// <summary>
  78         /// 文字列をコードポイント単位に分割して返します
  79         /// </summary>
  80         public static IEnumerable<int> ToCodepoints(this string s)
  81         {
  82             if (s == null)
  83                 throw new ArgumentNullException(nameof(s));
  84
  85             IEnumerable<int> GetEnumerable(string input)
  86             {
  87                 var i = 0;
  88                 var length = input.Length;
  89                 while (i < length)
  90                 {
  91                     if (char.IsSurrogatePair(input, i))
  92                     {
  93                         yield return char.ConvertToUtf32(input, i);
  94                         i += 2;
  95                     }
  96                     else
  97                     {
  98                         yield return input[i];
  99                         i++;
 100                     }
 101                 }
 102             }
 103
 104             return GetEnumerable(s);
 105         }
 106
 107         /// <summary>
 108         /// 指定された部分文字列のコードポイント単位での文字数を返す
 109         /// </summary>
 110         /// <param name="s">文字列</param>
 111         /// <param name="start">開始位置</param>
 112         /// <param name="end">終了位置</param>
 113         public static int GetCodepointCount(this string s, int start, int end)
 114         {
 115             if (s == null)
 116                 throw new ArgumentNullException(nameof(s));
 117             if (start < 0 || start > s.Length)
 118                 throw new ArgumentOutOfRangeException(nameof(start));
 119             if (end < 0 || end > s.Length)
 120                 throw new ArgumentOutOfRangeException(nameof(end));
 121             if (start > end)
 122                 throw new ArgumentOutOfRangeException(nameof(start));
 123
 124             var count = 0;
 125             for (var i = start; i < end; i += char.IsSurrogatePair(s, i) ? 2 : 1)
 126                 count++;
 127
 128             return count;
 129         }
 130
 131         public static Task ForEachAsync<T>(this IObservable<T> observable, Action<T> subscriber)
 132             => ForEachAsync(observable, value => { subscriber(value); return Task.CompletedTask; });
 133
 134         public static Task ForEachAsync<T>(this IObservable<T> observable, Func<T, Task> subscriber)
 135             => ForEachAsync(observable, subscriber, CancellationToken.None);
 136
 137         public static Task ForEachAsync<T>(this IObservable<T> observable, Action<T> subscriber, CancellationToken cancellationToken)
 138             => ForEachAsync(observable, value => { subscriber(value); return Task.CompletedTask; }, cancellationToken);
 139
 140         public static async Task ForEachAsync<T>(this IObservable<T> observable, Func<T, Task> subscriber, CancellationToken cancellationToken)
 141         {
 142             var observer = new ForEachObserver<T>(subscriber);
 143
 144             using (var unsubscriber = observable.Subscribe(observer))
 145             using (cancellationToken.Register(() => unsubscriber.Dispose()))
 146                 await observer.Task.ConfigureAwait(false);
 147         }
 148
 149         private class ForEachObserver<T> : IObserver<T>
 150         {
 151             private readonly Func<T, Task> subscriber;
 152             private readonly TaskCompletionSource<int> tcs = new TaskCompletionSource<int>();
 153
 154             public Task Task
 155                 => this.tcs.Task;
 156
 157             public ForEachObserver(Func<T, Task> subscriber)
 158                 => this.subscriber = subscriber;
 159
 160             public async void OnNext(T value)
 161             {
 162                 try
 163                 {
 164                     await this.subscriber(value);
 165                 }
 166                 catch (Exception ex)
 167                 {
 168                     this.tcs.TrySetException(ex);
 169                 }
 170             }
 171
 172             public void OnCompleted()
 173                 => this.tcs.TrySetResult(1);
 174
 175             public void OnError(Exception error)
 176                 => this.tcs.TrySetException(error);
 177         }
 178     }
 179 }