UniRxほげ

gistfile1.cs

            this.UpdateAsObservable()
                .TakeUntil(this.UpdateAsObservable().Where(_ => Input.GetMouseButtonUp(0)))
                .Scan(new List<Vector3>(), (list, _) =>
                {
                    Debug.Log("Scan");
                    return list;
                })
                .Where(list =>
                {
                    Debug.Log("Where");
                    var current = Camera.main.ScreenToWorldPoint(Input.mousePosition);
                    if (list.Count > 0)
                    {
                        if (Vector3.Distance(list[list.Count - 1], current) < .1f)
                        {
                            return false;
                        }
                    }
                    else
                    {
                        this.startPosition = current;
                    }

                    list.Add(current);
                    return true;
                })
                .Select(list => list[list.Count - 1])
                .Subscribe(p =>
                {
                    this.positions.Enqueue(p);
                    UpdateMeshAndCollider();

                    Observable.Timer(TimeSpan.FromMilliseconds(2000f))
                        .Subscribe(_ =>
                        {
                            this.positions.Dequeue();
                            UpdateMeshAndCollider();
                            Debug.Log(this);
                            Debug.Log(this.hoge);
                        });
                },
                () =>
                {
                });

hoge.cs

            var dragStream = this.UpdateAsObservable()
                .TakeUntil(this.UpdateAsObservable().Select(_ => Input.GetMouseButtonUp(0)))
                .Select(_ => Camera.main.ScreenToWorldPoint(Input.mousePosition));

            dragStream
                .Zip(dragStream.Skip(1), (prev, current) => Vector3.Distance(prev, current))
                .Scan(0f, (acc, distance) =>
                {
                    return acc += distance;
                })
                .Where(acc => acc >= 100)
                .Subscribe(acc =>
                {
                });