将基于回调的类包装到异步类

Question

我正在引用一个类，它使用回调而不是异步操作来执行各种要求很高的操作。例如：

class CallbackClass : SomeSdkCallbacks
{
    public void RequestData()
    {
        // We call this to request some data.
        // After some time, this will trigger OnDataReturned to be called
    }

    public void OnDataReturned(DataObject data)
    {
        // This will be called automatically with returned data via SomeSdkCallbacks
    }
}

此类结构有很多实例。

我想要做的是围绕这个创建一个包装类，以简化它的使用。我目前的结构是：

class MyWrapperClass
{
    CallbackClass CallbackClass;

    public MyWrapperClass()
    {
        this.CallbackClass = new CallbackClass();
    }

    public DataObject GetData()
    {
        this.CallbackClass.RequestData();

        // Somehow wait until this.CallbackClass.OnDataReturned is called?

        // Somehow get the data that would be passed in to this.CallbackClass.OnDataReturned()???
    }
}

将“回调”架构封装成单个异步方法的最佳方法是什么？

编辑：为了澄清，理想情况下，我想将其打包成一个方法，该方法可以在单个请求中返回数据。请参阅我的示例中的 MyWrapperClass.GetData() 方法了解我的理想结构。

编辑 2：我知道这种期望的架构是错误的形式。不幸的是，这是我要求的结构。

Answer 1

我想这就是你想要的：

        class CallbackClass<T>
        {
            private TaskCompletionSource<T> task = new TaskCompletionSource<T>();

            public void RequestData()
            {
               
            }

            public void OnDataReturned(T data)
            {
                task.SetResult(data);
            }

            public Task<T> Task { get { return task.Task; } }
        }

        class MyWrapperClass
        {
            public Task<DataObject> GetData()
            {
                var cls = new CallbackClass<DataObject>();

                cls.RequestData();

                return cls.Task;
            }
        }

请注意，必须为每个操作创建TaskCompletionSource，这样您就不会为两个不同的调用使用同一个。有了这个，您可以使用async 关键字。 This 可能会有所帮助。

Answer 2

在您的情况下，您可以在 CallBackClass 上添加一些事件。 喜欢这里：

class CallbackClass : SomeSdkCallbacks
{
    public event Action<object> DataReturnedEvent;
    public void RequestData()
    {
        // We call this to request some data.
        // After some time, this will trigger OnDataReturned to be called
    }
    public void OnDataReturned(DataObject data)
    {
        DataReturnedEvent?.Invoke(data);
    }
}

你可以在包装类中使用事件

class MyWrapperClass
{
    CallbackClass CallbackClass;

    public MyWrapperClass()
    {
        this.CallbackClass = new CallbackClass();
        CallbackClass.DataReturnedEvent =+ ProcessData;
    }
    private void ProcessData(object Data)
    {
        //some data processing
    }
    public DataObject GetData()
    {
        this.CallbackClass.RequestData()               
    }
}