C#

private void Window_Loaded(object sender, RoutedEventArgs e)
{
    var Moves = Observable.FromEventPattern<MouseEventArgs>(this, "MouseMove").Select(evt=>evt.EventArgs.GetPosition(this));
    Moves.Subscribe(evt => {
        this.Title = evt.ToString();
    });
}

private void Window_Loaded(object sender, RoutedEventArgs e)
{
    var Moves = Observable.FromEventPattern<MouseEventArgs>(this, "MouseMove").Select(evt=>evt.EventArgs.GetPosition(this));
    Moves.Subscribe(evt => {
        this.Title = evt.ToString();
    });

    //Does not exist
    Moves.Dispose();
}

/// <summary>
/// Handles the FileSystemWatcher's Created event. This is fired when a file starts being 
/// copied into the target folder
/// </summary>
private void OnCreated(object sender, FileSystemEventArgs e)
{
    if (HasAnotherFileEventOccuredRecently(e.FullPath))
    {
        return;
    }

    QueueFile(e);
}

/// <summary>
/// Places a file in the queue of files waiting for to become ready
/// </summary>
private void QueueFile(FileSystemEventArgs fileSystemEventArgs)
{
    var worker = new BackgroundWorker();
    worker.DoWork += Worker_DoWork;
    worker.RunWorkerCompleted += Worker_RunWorkerCompleted;

    _queue.Add(worker);

    worker.RunWorkerAsync(fileSystemEventArgs);
}

private void Worker_DoWork(object sender, DoWorkEventArgs e)
{
    var args = (FileSystemEventArgs)e.Argument;

    if (args != null)
    {
        while (!IsFileAvailable(args.FullPath))
        {
            // Loop until the file is read/write
        }
    }

    e.Result = args;
}

private void Worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
    var args = (FileSystemEventArgs)e.Result;

    // Remove the worker from the queue
    var worker = _queue.FirstOrDefault(x => x == sender);
    if (worker != null)
    {
        worker.Dispose();
        _queue.Remove(worker);
    }

    // Raise the event so listeners off this class are notified when the 
    // file is ready to process
    this.OnCreated(args);
}

/// <summary>
/// Determines whether a file is available for Read/Write.
/// </summary>
public bool IsFileAvailable(string filename)
{
    var results = false;

    try
    {
        using (var inputStream = File.Open(filename, FileMode.Open, FileAccess.Read, FileShare.None))
        {
            results = inputStream.Length > 0;
        }
    }
    catch (Exception)
    {
        results = false;
    }

    return results;
}

var dt = SqlDataSourceEnumerator.Instance.GetDataSources();