TaskCompletionSource никогда не завершается

У меня есть соединение с веб-сокетом, и я хочу создать для него методы получения. Я использовал этот пример.

Это часть модели данных:

public class Message
{        
    public string MessageType { get; set; }
}

public class SensorData : Message
{
    public float Temperature { get; set; }

    public float Humidity { get; set; }

    public float Pressure { get; set; }
}

Это класс websocket:

public WebSocketConnection(string url)
{
    socket = new WebSocket(url);
}

private WebSocket socket;

public int Timeout = 10000;

public void Connect()
{
    socket.Connect();
    socket.OnMessage += Socket_OnMessage;

}

public void Disconnect()
{
    socket.Close();
    socket.OnMessage -= Socket_OnMessage;
}        

public event EventHandler<OnSensorDataEventArgs> SensorDataReveived;

private void Socket_OnMessage(object sender, MessageEventArgs e)
{
    var msg = JsonConvert.DeserializeObject<Message>(e.Data);

    switch (msg.MessageType)
    {
        case "other message types":
            {
                ...                       
            }
        case "SensorData":
            {
                SensorDataReveived?.Invoke(this, new OnSensorDataEventArgs(JsonConvert.DeserializeObject<SensorData>(e.Data)));
                break;
            }
    }
}

public Task<SensorData> GetSensorData()
{
        var msg = JsonConvert.SerializeObject(new Message() { MessageType = "RequestSensorData" });

    var tcs = new TaskCompletionSource<SensorData>();

    SensorDataReveived += (sender, e) => {
        tcs.SetResult(e.SensorData);
    };

    socket.Send(msg);

    return tcs.Task;
}

Проблема в методе GetSensorData. Когда вызывается socket.Send (msg), сервер websocket отвечает и событие запускается, но после вызова SetResult ничего не происходит. Я уже пробовал TaskCreationOptions.RunContinuationsAsynchronously и обертывал SetResult в Task.Run, но это не помогло.

private async void BtnShowSensorData_Clicked(object sender, EventArgs e)
{
    var sensorData = await connection.GetSensorData(); //Connection is an instance of WebSocketConnection
    labelTemperature.Text = "  Temperature: " + sensorData.Temperature.ToString();
    labelHumidity.Text = "  Humidity: " + sensorData.Humidity.ToString();
    labelPressure.Text = "  Pressure: " + sensorData.Pressure.ToString();
} 

Кто и как вызывает GetSensorData?

Camilo Terevinto 26.10.2018 00:03

@CamiloTerevinto Когда пользователь нажимает кнопку, метод вызывается с ожиданием, и должны отображаться данные датчика.

Mr.Sheep 26.10.2018 00:06

Что ж, это происходит должен ... пожалуйста, опубликуйте этот код, если вы ожидаете, что мы сможем помочь

Camilo Terevinto 26.10.2018 00:08

@CamiloTerevinto, ладно, извините, не ожидайте, что это будет актуально.

Mr.Sheep 26.10.2018 00:18
Стоит ли изучать PHP в 2023-2024 годах?
Стоит ли изучать PHP в 2023-2024 годах?
Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Приемы CSS-макетирования - floats и Flexbox
Приемы CSS-макетирования - floats и Flexbox
Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...
Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest
В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...
Концепция локализации и ее применение в приложениях React ⚡️
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
0
4
68
0

Другие вопросы по теме