void reset()
        {
            std::lock_guard<std::mutex> lock(m_lock);
            assert(m_callbacks.empty());
            m_signaled = false;
            m_callbacks.clear();
        }

TEST(start, propogates_exception_from_negotiate_and_starts_again)
{
    auto http_client = std::make_shared<test_http_client>([](const std::string& url, http_request, cancellation_token) -> http_response
        {
            throw custom_exception();
        });

    auto websocket_client = create_test_websocket_client();
    auto hub_connection = hub_connection_builder::create("http://fakeuri")
        .with_logging(std::make_shared<memory_log_writer>(), trace_level::none)
        .with_http_client_factory([http_client](const signalr_client_config& config)
            {
                http_client->set_scheduler(config.get_scheduler());
                return http_client;
            })
        .with_websocket_factory([websocket_client](const signalr_client_config&) { return websocket_client; })
        .build();

    auto mre = manual_reset_event<void>();
    hub_connection.start([&mre](std::exception_ptr exception)
        {
            mre.set(exception);
        });

    try
    {
        mre.get();
        ASSERT_TRUE(false);
    }
    catch (const custom_exception& e)
    {
        ASSERT_STREQ("custom exception", e.what());
    }

    hub_connection.start([&mre](std::exception_ptr exception)
        {
            
        }); ///<-------- here assertion fails

    ASSERT_EQ(connection_state::disconnected, hub_connection.get_connection_state());
}