DXFeed.hpp

// Copyright (c) 2025 Devexperts LLC.
// SPDX-License-Identifier: MPL-2.0
 
#pragma once
 
#include "../internal/Conf.hpp"
 
DXFCXX_DISABLE_MSC_WARNINGS_PUSH(4251)
 
#include "../internal/CEntryPointErrors.hpp"
#include "../internal/Common.hpp"
#include "../internal/Isolate.hpp"
#include "../internal/JavaObjectHandle.hpp"
#include "../internal/managers/EntityManager.hpp"
#include "../promise/Promise.hpp"
#include "./DXFeedSubscription.hpp"
 
#include <memory>
#include <unordered_set>
 
DXFCPP_BEGIN_NAMESPACE
 
struct DXEndpoint;
class EventTypeEnum;
struct IndexedTxModelImpl;
struct TimeSeriesTxModelImpl;
 
/**
 * Main entry class for dxFeed API (<b>read it first</b>).
 *
 * <h3>Sample usage</h3>
 *
 * This section gives sample usage scenarios.
 *
 * <h4>Default singleton instance</h4>
 *
 * There is a singleton instance of the feed that is returned by DXFeed::getInstance() method.
 * It is created on the first use with default configuration properties that are explained in detail in
 * documentation for DXEndpoint class in the "Default properties" section.
 *
 * <p>In particular,
 * you can provide a default address to connect and credentials  using
 * "@ref DXEndpoint::DXFEED_ADDRESS_PROPERTY "dxfeed.address"",
 * "@ref DXEndpoint::DXFEED_USER_PROPERTY "dxfeed.user"", and
 * "@ref DXEndpoint::DXFEED_PASSWORD_PROPERTY "dxfeed.password""
 * system properties or by putting them into
 * "@ref DXEndpoint::DXFEED_PROPERTIES_PROPERTY "dxfeed.properties""
 * file in the same directory. dxFeed API samples come with a ready-to-use "<b>dxfeed.properties</b>"
 * file that contains an address of dxFeed demo feed at "<b>demo.dxfeed.com:7300</b>" and
 * demo access credentials.
 *
 * <h4>Subscribe for single event type</h4>
 *
 * The following code creates listener that prints mid-price for each quote
 * and subscribes for quotes on SPDR S&P 500 ETF symbol:
 * <pre><tt>
 * auto sub = @ref DXFeed "DXFeed"::@ref DXFeed::getInstance() "getInstance"()->@ref DXFeed::createSubscription()
 * "createSubscription"(Quote::TYPE);
 *
 * sub->@ref DXFeedSubscription::addEventListener() "addEventListener"<Quote>([](const auto& quotes) {
 *     for (const auto& quote : quotes) {
 *         std::cout << "Mid = " + (quote->@ref Quote::getBidPrice() "getBidPrice"() + quote->@ref Quote::getAskPrice()
 * "getAskPrice"()) / 2) << std::endl;
 *     }
 * });
 *
 * sub->@ref DXFeedSubscription::addSymbols() "addSymbols"("SPY");</tt></pre>
 *
 * Note, that order of calls is important here. By attaching listeners first and then setting
 * a subscription, we ensure that the current quote gets received by the listener. See DXFeedSubscription::addSymbols() for
 * details. If a set of symbols is changed first, then @ref DXFeedSubscription::addEventListener()
 * "sub->addEventListener" raises an IllegalStateException in JVM to protect from hard-to-catch bugs with potentially
 * missed events.
 *
 * <h4>Subscribe for multiple event types</h4>
 *
 * The following code creates listener that prints each received event and
 * subscribes for quotes and trades on SPDR S&P 500 ETF symbol:
 * <pre><tt>
 * auto sub = @ref DXFeed "DXFeed"::@ref DXFeed::getInstance() "getInstance"()->@ref DXFeed::createSubscription()
 * "createSubscription"({Quote::TYPE, Trade::TYPE});
 *
 * sub->@ref DXFeedSubscription::addEventListener() "addEventListener"([](auto&& events) {
 *     for (const auto& event : events) {
 *         std::cout << event << std::endl;
 *     }
 * });
 *
 * sub->@ref DXFeedSubscription::addSymbols() "addSymbols"("SPY");</tt></pre>
 *
 * <h4>Subscribe for event and query periodically its last value</h4>
 *
 * The following code subscribes for trades on SPDR S&P 500 ETF symbol and
 * prints last trade every second.
 *
 * <pre><tt>
 * using namespace std::chrono_literals;
 *
 * auto sub = @ref DXFeed "DXFeed"::@ref DXFeed::getInstance() "getInstance"()->@ref DXFeed::createSubscription()
 * "createSubscription"({Trade::TYPE});
 *
 * sub->@ref DXFeedSubscription::addSymbols() "addSymbols"("SPY");
 *
 * auto feed = @ref DXFeed "DXFeed"::@ref DXFeed::getInstance() "getInstance"();
 *
 * while (true) {
 *     std::cout << System.out.println(feed->@ref DXFeed::getLastEvent() "getLastEvent"(Trade::create("SPY")));
 *     std::this_thread::sleep_for(1000ms);
 * }</tt></pre>
 *
 * <h3>Threads and locks</h3>
 *
 * This class is thread-safe and can be used concurrently from multiple threads without external synchronization.
 */
struct DXFCPP_EXPORT DXFeed : SharedEntity {
    /// The alias to a type of shared pointer to the DXFeed object
    using Ptr = std::shared_ptr<DXFeed>;
 
    /// The alias to a type of unique pointer to the DXFeed object
    using Unique = std::unique_ptr<DXFeed>;
 
    friend struct DXEndpoint;
    friend struct TimeSeriesTxModelImpl;
    friend struct IndexedTxModelImpl;
 
    private:
    JavaObjectHandle<DXFeed> handle_{};
    static std::shared_ptr<DXFeed> create(void *feedHandle);
 
    void *getLastEventPromiseImpl(const EventTypeEnum &eventType, const SymbolWrapper &symbol) const;
 
    void *getLastEventsPromisesImpl(const EventTypeEnum &eventType, void *graalSymbolList) const;
 
    void *getIndexedEventsPromiseImpl(const EventTypeEnum &eventType, const SymbolWrapper &symbol,
                                      const IndexedEventSource &source) const;
 
    void *getTimeSeriesPromiseImpl(const EventTypeEnum &eventType, const SymbolWrapper &symbol, std::int64_t fromTime,
                                   std::int64_t toTime) const;
 
    std::shared_ptr<EventType> getLastEventIfSubscribedImpl(const EventTypeEnum &eventType,
                                                            const SymbolWrapper &symbol) const;
 
    std::vector<std::shared_ptr<EventType>> getIndexedEventsIfSubscribedImpl(const EventTypeEnum &eventType,
                                                                             const SymbolWrapper &symbol,
                                                                             const IndexedEventSource &source) const;
 
    std::vector<std::shared_ptr<EventType>> getTimeSeriesIfSubscribedImpl(const EventTypeEnum &eventType,
                                                                          const SymbolWrapper &symbol,
                                                                          std::int64_t fromTime,
                                                                          std::int64_t toTime) const;
 
    JavaObjectHandle<DXFeedSubscription>
    createTimeSeriesSubscriptionHandleFromEventClassList(const std::unique_ptr<EventClassList> &list) const;
 
    protected:
    DXFeed() noexcept;
 
    public:
    ~DXFeed() noexcept override;
 
    /**
     * Returns a default application-wide singleton instance of feed. Most applications use only a single
     * data-source and should rely on this method to get one. This is a shortcut to
     * @ref DXEndpoint "DXEndpoint"::@ref DXEndpoint::getInstance() "getInstance()"->@ref DXEndpoint::getFeed()
     * "getFeed()".
     *
     * @return The DXFeed instance
     */
    static std::shared_ptr<DXFeed> getInstance();
 
    /**
     * Attaches the given subscription to this feed. This method does nothing if the
     * corresponding subscription is already attached to this feed.
     *
     * <p> This feed publishes data to the attached subscription.
     * Application can attach an event listener via DXFeedSubscription::addEventListener to get notified about data
     * changes and can change its data subscription via DXFeedSubscription methods.
     *
     * <h3>Implementation notes</h3>
     *
     * This method adds a non-serializable ObservableSubscriptionChangeListener for the given subscription
     * via DXFeedSubscription::addChangeListener method.
     *
     * @param subscription The subscription.
     * @see DXFeedSubscription
     */
    void attachSubscription(const std::shared_ptr<DXFeedSubscription> &subscription) const;
 
    /**
     * Detaches the given subscription from this feed. This method does nothing if the
     * corresponding subscription is not attached to this feed.
     *
     * <h3>Implementation notes</h3>
     *
     * This method removes ObservableSubscriptionChangeListener from the given subscription
     * via DXFeedSubscription::removeChangeListener method.
     *
     * @param subscription The subscription.
     * @see DXFeedSubscription
     */
    void detachSubscription(const std::shared_ptr<DXFeedSubscription> &subscription) const;
 
    /**
     * Detaches the given subscription from this feed and clears data delivered to this subscription
     * by publishing empty events. This method does nothing if the
     * corresponding subscription is not attached to this feed.
     *
     * @param subscription The subscription.
     * @see DXFeed::detachSubscription()
     */
    void detachSubscriptionAndClear(const std::shared_ptr<DXFeedSubscription> &subscription) const;
 
    /**
     * Returns the last event for the specified event instance.
     * This method works only for event types that implement the LastingEvent marker interface.
     * This method <b>does not</b> make any remote calls to the uplink data provider.
     * It just retrieves the last received event from the local cache of this feed.
     * The events are stored in the cache only if there is some attached DXFeedSubscription that is subscribed to the
     * corresponding symbol and event type.
     * WildcardSymbol::ALL subscription does not count for that purpose.
     *
     * <p>Use @ref ::getLastEventPromise() "getLastEventPromise" method if an event needs to be requested in the absence
     * of subscription.
     *
     * <p> This method fills in the values for the last event into the `event argument.
     * If the last event is not available for any reason (no subscription, no connection to uplink, etc.)
     * then the event object is not changed.
     * This method always returns the same `event` instance passed to it as an argument.
     *
     * <p>This method provides no way to distinguish a case when there is no subscription from the case when
     * there is a subscription, but the event data have not arrived yet. It is recommended to use
     * @ref ::getLastEventIfSubscribed() "getLastEventIfSubscribed" method instead of this `getLastEvent` method to
     * fail-fast in case when the subscription was supposed to be set by the logic of the code, since
     * @ref ::getLastEventIfSubscribed() "getLastEventIfSubscribed" method returns `std::shared_ptr<E>(nullptr)` when
     * there is no subscription.
     *
     * <p>Note that this method does not work when DXEndpoint was created with
     * @ref DXEndpoint::Role::STREAM_FEED "STREAM_FEED" role (never fills in the event).
     *
     * @tparam E The type of event.
     * @param event The event.
     * @return The same event.
     */
    template <Derived<LastingEvent> E> std::shared_ptr<E> getLastEvent(std::shared_ptr<E> event) {
        if (auto last = getLastEventIfSubscribed<E>(event->getEventSymbol())) {
            event->assign(last);
        }
 
        return event;
    }
 
    /**
     * Returns the last events for the specified list of event instances.
     * This is a bulk version of @ref ::getLastEvent() "getLastEvent" method.
     *
     * <p>Note, that this method does not work when DXEndpoint was created with
     * @ref DXEndpoint::Role::STREAM_FEED "STREAM_FEED" role.
     *
     * @tparam Collection The collection type.
     * @param events The collection of shared ptrs of events.
     * @return The same collection of shared ptrs of events.
     */
    template <typename Collection, typename Element = std::decay_t<decltype(std::begin(Collection()))>,
              typename Event = std::decay_t<decltype(*Element())>>
    const Collection &getLastEvents(const Collection &events) {
        static_assert(
            std::is_same_v<Element, std::shared_ptr<Event>> && std::is_base_of_v<LastingEvent, Event>,
            "The collection element must be of type `std::shared_ptr<Event>`, where `Event` is a descendant of "
            "`LastingEvent`");
 
        for (auto e : events) {
            getLastEvent(e);
        }
 
        return events;
    }
 
    /**
     * Returns the last event for the specified event type and symbol if there is a subscription for it.
     * This method works only for event types that implement the LastingEvent marker interface.
     * This method <b>does not</b> make any remote calls to the uplink data provider.
     * It just retrieves the last received event from the local cache of this feed.
     * The events are stored in the cache only if there is some attached DXFeedSubscription that is subscribed to the
     * corresponding event type and symbol.
     * The subscription can also be permanently defined using DXEndpoint properties.
     * WildcardSymbol::ALL subscription does not count for that purpose.
     * If there is no subscription, then this method returns `std::shared_ptr<E>(nullptr)`.
     *
     * <p>If there is a subscription, but the event has not arrived from the uplink data provider,
     * this method returns a non-initialized event object: its @ref EventType#getEventSymbol() "eventSymbol"
     * property is set to the requested symbol, but all the other properties have their default values.
     *
     * <p>Use @ref ::getLastEventPromise() "getLastEventPromise" method if an event needs to be requested in the
     * absence of subscription.
     *
     * <p>Note that this method does not work when DXEndpoint} was created with @ref DXEndpoint::Role::STREAM_FEED
     * "STREAM_FEED" role (always returns `std::shared_ptr<E>(nullptr)`).
     *
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @return the event or `std::shared_ptr<E>(nullptr)` if there is no subscription for the specified event type and
     * symbol.
     */
    template <Derived<LastingEvent> E> std::shared_ptr<E> getLastEventIfSubscribed(const SymbolWrapper &symbol) {
        // https://youtrack.jetbrains.com/issue/RSCPP-15139
        // https://gcc.gnu.org/bugzilla/show_bug.cgi?id=67965
        // https://bugs.llvm.org/show_bug.cgi?id=25179
        // ReSharper disable once CppRedundantTemplateKeyword
        return getLastEventIfSubscribedImpl(E::TYPE, symbol)->template sharedAs<E>();
    }
 
    /**
     * Creates a new subscription for a single event type that is <i>attached</i> to this feed.
     * This method creates a new DXFeedSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * auto sub = dxfcpp::DXFeed::getInstance()->createSubscription(dxfcpp::Quote::TYPE);
     * ```
     *
     * @param eventType The type of event
     * @return The new subscription
     */
    std::shared_ptr<DXFeedSubscription> createSubscription(const EventTypeEnum &eventType) const;
 
    /**
     * Creates new subscription for multiple event types that is <i>attached</i> to this feed.
     * This method creates new DXFeedSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * auto eventTypes = {dxfcpp::Quote::TYPE, dxfcpp::TimeAndSale::TYPE};
     *
     * auto sub = dxfcpp::DXFeed::getInstance()->createSubscription(eventTypes.begin(), eventTypes.end());
     * ```
     *
     * ```cpp
     * std::vector types{dxfcpp::Quote::TYPE, dxfcpp::Trade::TYPE, dxfcpp::Summary::TYPE};
     *
     * auto sub = dxfcpp::DXFeed::getInstance()->createSubscription(types.begin(), types.end());
     * ```
     *
     * ```cpp
     * std::set types{dxfcpp::Quote::TYPE, dxfcpp::Trade::TYPE, dxfcpp::Summary::TYPE};
     * auto endpoint = dxfcpp::DXEndpoint::newBuilder()->withRole(dxfcpp::DXEndpoint::Role::FEED)->build();
     * auto sub = endpoint->getFeed()->createSubscription(eventTypes.begin(), eventTypes.end());
     *
     * endpoint->connect("demo.dxfeed.com:7300");
     * ```
     *
     * @tparam EventTypeIt The iterator type of the collection of event types
     * @param begin The start iterator
     * @param end The end iterator
     * @return The new subscription
     */
    template <typename EventTypeIt>
    std::shared_ptr<DXFeedSubscription> createSubscription(EventTypeIt begin, EventTypeIt end) {
        if constexpr (Debugger::isDebug) {
            // ReSharper disable once CppDFAUnreachableCode
            Debugger::debug("{}::createSubscription(eventTypes = " + namesToString(begin, end) + ")");
        }
 
        auto sub = DXFeedSubscription::create(begin, end);
 
        attachSubscription(sub);
 
        return sub;
    }
 
    /**
     * Creates new subscription for multiple event types that is <i>attached</i> to this feed.
     * This method creates new DXFeedSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * auto sub = endpoint->getFeed()->createSubscription({dxfcpp::Quote::TYPE, dxfcpp::TimeAndSale::TYPE});
     * ```
     *
     * @param eventTypes The initializer list of event types
     * @return The new subscription
     */
    std::shared_ptr<DXFeedSubscription> createSubscription(std::initializer_list<EventTypeEnum> eventTypes) const;
 
    /**
     * Creates new subscription for multiple event types that is <i>attached</i> to this feed.
     * This method creates a new DXFeedSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * auto sub = endpoint->getFeed()->createSubscription(std::unordered_set{dxfcpp::Quote::TYPE,
     * dxfcpp::TimeAndSale::TYPE});
     * ```
     *
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * std::vector types = {dxfcpp::Quote::TYPE, dxfcpp::TimeAndSale::TYPE};
     * auto sub = endpoint->getFeed()->createSubscription(types);
     * ```
     *
     * @tparam EventTypesCollection The class of the collection of event types
     * @param eventTypes The collection of event types
     * @return The new subscription
     */
    template <typename EventTypesCollection>
    std::shared_ptr<DXFeedSubscription> createSubscription(const EventTypesCollection &eventTypes) {
        if constexpr (Debugger::isDebug) {
            // ReSharper disable once CppDFAUnreachableCode
            auto begin = std::begin(eventTypes);
            auto end = std::end(eventTypes);
 
            Debugger::debug(toString() + "::createSubscription(eventTypes = " + namesToString(begin, end) + ")");
        }
 
        auto sub = DXFeedSubscription::create(eventTypes);
 
        attachSubscription(sub);
 
        return sub;
    }
 
    /**
     * Creates a new subscription for a single event type that is <i>attached</i> to this feed.
     * This method creates a new DXFeedTimeSeriesSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * auto sub = endpoint->getFeed()->createTimeSeriesSubscription(dxfcpp::TimeAndSale::TYPE);
     * ```
     *
     * @param eventType The type of event
     * @return The new subscription
     */
    std::shared_ptr<DXFeedTimeSeriesSubscription> createTimeSeriesSubscription(const EventTypeEnum &eventType) const;
 
    /**
     * Creates new subscription for multiple event types that is <i>attached</i> to this feed.
     * This method creates new DXFeedTimeSeriesSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * auto eventTypes = {dxfcpp::Underlying::TYPE, dxfcpp::TimeAndSale::TYPE};
     * auto sub = endpoint->getFeed()->createTimeSeriesSubscription(eventTypes.begin(), eventTypes.end());
     * ```
     *
     * ```cpp
     * std::vector types{dxfcpp::Underlying::TYPE, dxfcpp::TimeAndSale::TYPE, dxfcpp::Candle::TYPE};
     *
     * auto sub = dxfcpp::DXFeed::getInstance()->createTimeSeriesSubscription(types.begin(), types.end());
     * ```
     *
     * ```cpp
     * std::set types{dxfcpp::Underlying::TYPE, dxfcpp::TimeAndSale::TYPE, dxfcpp::Candle::TYPE};
     * auto endpoint = dxfcpp::DXEndpoint::newBuilder()->withRole(dxfcpp::DXEndpoint::Role::FEED)->build();
     * auto sub = endpoint->getFeed()->createTimeSeriesSubscription(eventTypes.begin(), eventTypes.end());
     *
     * endpoint->connect("demo.dxfeed.com:7300");
     * ```
     *
     * @tparam EventTypeIt The iterator type of the collection of event types
     * @param begin The start iterator
     * @param end The end iterator
     * @return The new subscription
     */
    template <typename EventTypeIt>
    std::shared_ptr<DXFeedTimeSeriesSubscription> createTimeSeriesSubscription(EventTypeIt begin, EventTypeIt end) {
        if constexpr (Debugger::isDebug) {
            // ReSharper disable once CppDFAUnreachableCode
            Debugger::debug("{}::createTimeSeriesSubscription(eventTypes = " + namesToString(begin, end) + ")");
        }
 
        for (EventTypeIt iter = begin; iter != end; ++iter) {
            if (!iter->isTimeSeries()) {
                throw InvalidArgumentException("DXFeed::createTimeSeriesSubscription(): event type " +
                                               iter->getClassName() + " is not TimeSeries");
            }
        }
 
        auto list = EventClassList::create(begin, end);
        auto sub = RequireMakeShared<DXFeedTimeSeriesSubscription>::createShared(
            begin, end, std::move(createTimeSeriesSubscriptionHandleFromEventClassList(list)));
        auto id = ApiContext::getInstance()->getManager<EntityManager<DXFeedSubscription>>()->registerEntity(sub);
 
        dxfcpp::ignoreUnused(id);
 
        attachSubscription(sub);
 
        return sub;
    }
 
    /**
     * Creates new subscription for multiple event types that is <i>attached</i> to this feed.
     * This method creates a new DXFeedTimeSeriesSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * auto sub = endpoint->getFeed()->createTimeSeriesSubscription({dxfcpp::Underlying::TYPE,
     * dxfcpp::TimeAndSale::TYPE});
     * ```
     *
     * @param eventTypes The initializer list of event types
     * @return The new subscription
     */
    std::shared_ptr<DXFeedTimeSeriesSubscription>
    createTimeSeriesSubscription(std::initializer_list<EventTypeEnum> eventTypes);
 
    /**
     * Creates new subscription for multiple event types that is <i>attached</i> to this feed.
     * This method creates a new DXFeedTimeSeriesSubscription and invokes DXFeed::attachSubscription().
     *
     * Example:
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * auto sub =
     *     endpoint->getFeed()->createTimeSeriesSubscription(std::unordered_set{dxfcpp::Underlying::TYPE,
     *                                                                          dxfcpp::TimeAndSale::TYPE});
     * ```
     *
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * std::vector types = {dxfcpp::Underlying::TYPE, dxfcpp::TimeAndSale::TYPE};
     * auto sub = endpoint->getFeed()->createTimeSeriesSubscription(types);
     * ```
     *
     * @tparam EventTypesCollection The class of the collection of event types
     * @param eventTypes The collection of event types
     * @return The new subscription
     */
    template <typename EventTypesCollection>
    std::shared_ptr<DXFeedTimeSeriesSubscription> createTimeSeriesSubscription(const EventTypesCollection &eventTypes) {
        if constexpr (Debugger::isDebug) {
            // ReSharper disable once CppDFAUnreachableCode
            auto dbgBegin = std::begin(eventTypes);
            auto dbgEnd = std::end(eventTypes);
 
            // ReSharper disable once CppDFAUnreachableCode
            Debugger::debug(toString() +
                            "::createTimeSeriesSubscription(eventTypes = " + namesToString(dbgBegin, dbgEnd) + ")");
        }
 
        auto begin = std::begin(eventTypes);
        auto end = std::end(eventTypes);
 
        return createTimeSeriesSubscription(begin, end);
    }
 
    /**
     * Requests the last event for the specified event type and symbol.
     * This method works only for event types that implement LastingEvent marker "interface".
     * This method requests the data from the uplink data provider, creates a new event of the specified event type
     * and completes the resulting promise with this event.
     *
     * <p>The promise is canceled when the underlying DXEndpoint is @ref DXEndpoint::close() "closed".
     * If the event is not available for any transient reason (no subscription, no connection to uplink, etc.),
     * then the resulting promise completes when the issue is resolved, which may involve an arbitrarily long wait.
     * Use Promise::await() method to specify timeout while waiting for a promise to complete.
     * If the event is permanently not available (not supported), then the promise completes exceptionally with
     * JavaException "IllegalArgumentException".
     *
     * <p>There is a bulk version of this method that works much faster for a single event type and multiple symbols.
     * See getLastEventsPromises().
     *
     * <p>Note that this method does not work when DXEndpoint was created with @ref DXEndpoint::Role::STREAM_FEED
     * "STREAM_FEED" role (promise completes exceptionally).
     *
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @return The promise for the result of the request.
     */
    template <Derived<LastingEvent> E>
    std::shared_ptr<Promise<std::shared_ptr<E>>> getLastEventPromise(const SymbolWrapper &symbol) const {
        return std::make_shared<Promise<std::shared_ptr<E>>>(getLastEventPromiseImpl(E::TYPE, symbol));
    }
 
    /**
     * Requests the last events for the specified event type and a collection of symbols.
     * This method works only for event types that implement LastingEvent marker "interface".
     * This method requests the data from the uplink data provider,
     * creates new events of the specified evet type and completes the resulting promises with these events.
     *
     * <p>This is a bulk version of DXFeed::getLastEventPromise() method.
     *
     * <p>The promise is canceled when the underlying DXEndpoint is @ref DXEndpoint::close() "closed".
     * If the event is not available for any transient reason (no subscription, no connection to uplink, etc.),
     * then the resulting promise completes when the issue is resolved, which may involve an arbitrarily long wait.
     * Use Promise::await() method to specify timeout while waiting for a promise to complete.
     * If the event is permanently not available (not supported), then the promise
     * completes exceptionally with JavaException "IllegalArgumentException".
     *
     * <p>Use the following pattern of code to acquire multiple events (either for multiple symbols and/or multiple
     * events) and wait with a single timeout for all of them:
     *
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * std::vector<dxfcpp::SymbolWrapper> symbols{"AAPL&Q", "IBM&Q"};
     * auto promises = endpoint->getFeed()->getLastEventsPromises<Quote>(symbols.begin(), symbols.end());
     *
     * // combine the list of promises into one with Promises utility method and wait
     * dxfcpp::Promises::allOf(*promises)->awaitWithoutException(std::chrono::seconds(timeout));
     *
     * // now iterate the promises to retrieve results
     * for (const auto& promise : *promises) {
     *     auto quote = promise.getResult(); // InvalidArgumentException if result is nullptr
     *     doSomethingWith(quote);
     *     // std::cout << quote->toString() << std::endl;
     * }
     * ```
     *
     * <p>Note, that this method does not work when DXEndpoint was created with @ref DXEndpoint::Role::STREAM_FEED
     * "STREAM_FEED" role (promise completes exceptionally).
     *
     * @tparam E The event type.
     * @tparam SymbolIt The symbols collection's iterator type.
     * @param begin The beginning of the collection of symbols (SymbolWrapper).
     * @param end The end of the collection of symbols (SymbolWrapper).
     * @return The list of promises for the result of the requests, one item in list per symbol.
     */
    template <Derived<LastingEvent> E, typename SymbolIt>
    std::shared_ptr<PromiseList<E>> getLastEventsPromises(SymbolIt begin, SymbolIt end) const {
        auto list = SymbolWrapper::SymbolListUtils::toGraalListUnique(begin, end);
 
        return PromiseList<E>::create(getLastEventsPromisesImpl(E::TYPE, list.get()));
    }
 
    /**
     * Requests the last events for the specified event type and a collection of symbols.
     * This method works only for event types that implement LastingEvent marker "interface".
     * This method requests the data from the uplink data provider,
     * creates new events of the specified evet type and completes the resulting promises with these events.
     *
     * <p>This is a bulk version of DXFeed::getLastEventPromise() method.
     *
     * <p>The promise is cancelled when the underlying DXEndpoint is @ref DXEndpoint::close() "closed".
     * If the event is not available for any transient reason (no subscription, no connection to uplink, etc.),
     * then the resulting promise completes when the issue is resolved, which may involve an arbitrarily long wait.
     * Use Promise::await() method to specify timeout while waiting for a promise to complete.
     * If the event is permanently not available (not supported), then the promise
     * completes exceptionally with JavaException "IllegalArgumentException".
     *
     * <p>Use the following pattern of code to acquire multiple events (either for multiple symbols and/or multiple
     * events) and wait with a single timeout for all of them:
     *
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * std::vector<dxfcpp::SymbolWrapper> symbols{"AAPL&Q", "IBM&Q"};
     * auto promises = endpoint->getFeed()->getLastEventsPromises<Quote>(symbols);
     *
     * // combine the list of promises into one with Promises utility method and wait
     * dxfcpp::Promises::allOf(*promises)->awaitWithoutException(std::chrono::seconds(timeout));
     *
     * // now iterate the promises to retrieve results
     * for (const auto& promise : *promises) {
     *     doSomethingWith(promise.getResult()); // InvalidArgumentException if result is nullptr
     * }
     * ```
     *
     * <p>Note, that this method does not work when DXEndpoint was created with @ref DXEndpoint::Role::STREAM_FEED
     * "STREAM_FEED" role (promise completes exceptionally).
     *
     * @tparam E The event type.
     * @tparam SymbolsCollection The symbol collection's type.
     * @param collection The symbol collection.
     * @return The list of promises for the result of the requests, one item in the list per symbol.
     */
    template <Derived<LastingEvent> E, ConvertibleToSymbolWrapperCollection SymbolsCollection>
    std::shared_ptr<PromiseList<E>> getLastEventsPromises(const SymbolsCollection &collection) const {
        auto begin = std::begin(collection);
        auto end = std::end(collection);
 
        return getLastEventsPromises<E>(begin, end);
    }
 
    /**
     * Requests the last events for the specified event type and a collection of symbols.
     * This method works only for event types that implement LastingEvent marker "interface".
     * This method requests the data from the uplink data provider,
     * creates new events of the specified event type and completes the resulting promises with these events.
     *
     * <p>This is a bulk version of DXFeed::getLastEventPromise() method.
     *
     * <p>The promise is canceled when the underlying DXEndpoint is @ref DXEndpoint::close() "closed".
     * If the event is not available for any transient reason (no subscription, no connection to uplink, etc.),
     * then the resulting promise completes when the issue is resolved, which may involve an arbitrarily long wait.
     * Use Promise::await() method to specify timeout while waiting for a promise to complete.
     * If the event is permanently not available (not supported), then the promise
     * completes exceptionally with JavaException "IllegalArgumentException".
     *
     * <p>Use the following pattern of code to acquire multiple events (either for multiple symbols and/or multiple
     * events) and wait with a single timeout for all of them:
     *
     * ```cpp
     * const auto endpoint = dxfcpp::DXEndpoint::create()->connect(address);
     * auto promises = endpoint->getFeed()->getLastEventsPromises<Quote>({"AAPL&Q", "IBM&Q"});
     *
     * // combine the list of promises into one with Promises utility method and wait
     * dxfcpp::Promises::allOf(*promises)->awaitWithoutException(std::chrono::seconds(timeout));
     *
     * // now iterate the promises to retrieve results
     * for (const auto& promise : *promises) {
     *     doSomethingWith(promise.getResult()); // InvalidArgumentException if result is nullptr
     * }
     * ```
     *
     * <p>Note, that this method does not work when DXEndpoint was created with @ref DXEndpoint::Role::STREAM_FEED
     * "STREAM_FEED" role (promise completes exceptionally).
     *
     * @tparam E The event type.
     * @param collection The symbol collection.
     * @return The list of promises for the result of the requests, one item in list per symbol.
     */
    template <Derived<LastingEvent> E>
    std::shared_ptr<PromiseList<E>> getLastEventsPromises(std::initializer_list<SymbolWrapper> collection) const {
        return getLastEventsPromises<E>(collection.begin(), collection.end());
    }
 
    /**
     * Requests a container of indexed events for the specified event type, symbol and source.
     * This method works only for event types that implement IndexedEvent "interface".
     * This method requests the data from the uplink data provider, creates a container of events of the specified
     * event type `E` and completes the resulting promise with this container. The events are ordered by @ref
     * IndexedEvent::getIndex() "index" in the container.
     *
     * <p> This method is designed for retrieval of a snapshot only.
     * Use IndexedEventModel if you need a container of indexed events that updates in real time.
     *
     * <p>The promise is cancelled when the underlying DXEndpoint is @ref DXEndpoint::close() "closed".
     * If the events are not available for any transient reason (no subscription, no connection to uplink, etc.),
     * then the resulting promise completes when the issue is resolved, which may involve an arbitrarily long wait.
     * Use Promise::await() method to specify timeout while waiting for promise to complete.
     * If the events are permanently not available (not supported), then the promise
     * completes exceptionally with JavaException "IllegalArgumentException".
     *
     * <p>Note that this method does not work when DXEndpoint was created with
     * @ref DXEndpoint::Role::STREAM_FEED "STREAM_FEED" role (promise completes exceptionally).
     *
     * <h3>Event source.</h3>
     *
     * Use the @ref IndexedEventSource::DEFAULT "DEFAULT" value for `source` with events that do not
     * have multiple sources (like Series). For events with multiple sources (like Order,
     * AnalyticOrder, OtcMarketsOrder and SpreadOrder), use an event-specific source class (for example, OrderSource).
     * This method does not support <em>synthetic</em> sources of orders (orders that are automatically
     * generated from Quote events).
     *
     * <p>This method does not accept an instance of IndexedEventSubscriptionSymbol as a `symbol`.
     * The later class is designed for use with DXFeedSubscription and to observe source-specific subscription
     * in DXPublisher.
     *
     * <h3>Event flags and consistent snapshot</h3>
     *
     * This method completes promise only when a consistent snapshot of indexed events has been received from
     * the data feed. The @ref IndexedEvent::getEventFlags() "eventFlags" property of the events in the resulting vector
     * is always zero.
     *
     * <p>Note that the resulting vector <em>should not</em> be used with DXPublisher::publishEvents() method, because
     * the latter expects events in a different order and with an appropriate flags set. See documentation on a specific
     * event class for details on how they should be published.
     *
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @param source The source.
     * @return The promise for the result of the request.
     */
    template <Derived<IndexedEvent> E>
    std::shared_ptr<Promise<std::vector<std::shared_ptr<E>>>>
    getIndexedEventsPromise(const SymbolWrapper &symbol, const IndexedEventSource &source) const {
        return std::make_shared<Promise<std::vector<std::shared_ptr<E>>>>(
            getIndexedEventsPromiseImpl(E::TYPE, symbol, source));
    }
 
    /**
     * Returns a vector of indexed events for the specified event type, symbol and source if there is a subscription
     * for it. This method works only for event types that implement IndexedEvent interface. This method <b>does not</b>
     * make any remote calls to the uplink data provider. It just retrieves last received events from the local cache of
     * this feed. The events are stored in the cache only if there is some attached DXFeedSubscription that is
     * subscribed to the corresponding event type, symbol and source. The subscription can also be permanently defined
     * using DXEndpoint properties. If there is no subscription, then this method returns an empty vector.
     * Otherwise, it creates a vector of events of the specified event type `E` and returns it.
     *
     * The events are ordered by @ref IndexedEvent::getIndex() "index" in the vector.
     *
     * <p>If there is a subscription, but the events have not arrived from the uplink data provider,
     * this method returns an empty vector.
     *
     * <p>Use @ref DXFeed::getIndexedEventsPromise() "getIndexedEventsPromise" method
     * if events need to be requested in the absence of subscription.
     *
     * <p>Note that this method does not work when DXEndpoint was created with @ref DXEndpoint::Role::STREAM_FEED
     * "STREAM_FEED" role (always returns an empty vector).
     *
     * <h3>Event source.</h3>
     *
     * Use the @ref IndexedEventSource::DEFAULT "DEFAULT" value for `source` with events that do not
     * have multiple sources (like Series). For events with multiple sources (like Order, AnalyticOrder,
     * OtcMarketsOrder and SpreadOrder), use an event-specific source class (for example, OrderSource).
     * This method does not support <em>synthetic</em> sources of orders (orders that are automatically generated from
     * Quote events).
     *
     * <p>This method does not accept an instance of IndexedEventSubscriptionSymbol as a `symbol`.
     * The later class is designed for use with DXFeedSubscription and to observe source-specific subscription
     * in @DXPublisher.
     *
     * <h3>Event flags and consistent snapshot</h3>
     *
     * This method returns a vector of events that are currently in the cache without any wait or delay, and it <b>does
     * not</b> guarantee that a consistent snapshot of events is returned. See IndexedEvent documentation for details.
     * The @ref IndexedEvent::getEventFlags() "eventFlags" property of the events in the resulting vector
     * is always zero regardless. Use @ref DXFeed::getIndexedEventsPromise() "getIndexedEventsPromise" method
     * if a consistent snapshot of events needs to be requested.
     *
     * <p>Note that the resulting vector <em>should not</em> be used with DXPublisher::publishEvents() method, because
     * the latter expects events in a different order and with an appropriate flags set. See documentation on a specific
     * event class for details on how they should be published.
     *
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @param source The source.
     * @return The vector of events or an empty vector if there is no subscription for the specified event
     * type, symbol and source.
     */
    template <Derived<IndexedEvent> E>
    std::vector<std::shared_ptr<E>> getIndexedEventsIfSubscribed(const SymbolWrapper &symbol,
                                                                 const IndexedEventSource &source) const {
        return convertEvents<EventType, E>(getIndexedEventsIfSubscribedImpl(E::TYPE, symbol, source));
    }
 
    /**
     * Requests time series of events for the specified event type, symbol and a range of time.
     *
     * This method works only for event types that implement TimeSeriesEvent "interface".
     * This method requests the data from the uplink data provider, creates a vector of events of the specified
     * event type `E` and completes the resulting promise with this container.
     *
     * The events are ordered by @ref TimeSeriesEvent::getTime() "time" in the container.
     *
     * <p> This method is designed for retrieval of a snapshot only.
     * Use TimeSeriesEventModel if you need a vector of time-series events that updates in real time.
     *
     * <p>The range and depth of events that are available with this service is typically constrained by
     * upstream data provider.
     *
     * <p>The promise is cancelled when the underlying DXEndpoint is @ref DXEndpoint::close() "closed".
     *
     * If events are not available for any transient reason (no subscription, no connection to uplink, etc.),
     * then the resulting promise completes when the issue is resolved, which may involve an arbitrarily long wait.
     * Use EventsPromiseMixin::await() method to specify timeout while waiting for promise to complete.
     * If events are permanently not available (not supported), then the promise
     * completes exceptionally with JavaException "IllegalArgumentException".
     *
     * <p>Note, that this method does not work when DXEndpoint was created with
     * @ref DXEndpoint::Role::STREAM_FEED "STREAM_FEED" role (promise completes exceptionally).
     *
     * <p>This method does not accept an instance of TimeSeriesSubscriptionSymbol as a `symbol`.
     * The later class is designed for use with DXFeedSubscription and to observe time-series subscription
     * in DXPublisher.
     *
     * <h3>Event flags</h3>
     *
     * This method completes promise only when a consistent snapshot of time series has been received from
     * the data feed. The @ref IndexedEvent::getEventFlags() "eventFlags" property of the events in the resulting
     * container is always zero.
     *
     * <p>Note that the resulting container <em>should not</em> be used with DXPublisher::publishEvents() method,
     * because the latter expects events in a different order and with an appropriate flags set. See documentation on a
     * specific event class for details on how they should be published.
     *
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @param fromTime The time, inclusive, to request events from (see TimeSeriesEvent::getTime()).
     * @param toTime The time, inclusive, to request events to (see TimeSeriesEvent::getTime()).
     *               Use `std::numeric_limits<std::int64_t>::max()` or `LLONG_MAX` macro to retrieve events without an
     *               upper limit on time.
     * @return The promise for the result of the request.
     */
    template <Derived<TimeSeriesEvent> E>
    std::shared_ptr<Promise<std::vector<std::shared_ptr<E>>>>
    getTimeSeriesPromise(const SymbolWrapper &symbol, std::int64_t fromTime, std::int64_t toTime) const {
        return std::make_shared<Promise<std::vector<std::shared_ptr<E>>>>(
            getTimeSeriesPromiseImpl(E::TYPE, symbol, fromTime, toTime));
    }
 
    /**
     * Returns time series of events for the specified event type, symbol and a range of time if there is a
     * subscription for it. This method <b>does not</b> make any remote calls to the uplink data provider. It just
     * retrieves last received events from the local cache of this feed. The events are stored in the cache only if
     * there is some attached DXFeedSubscription that is subscribed to the corresponding event type, symbol and time.
     * The subscription can also be permanently defined using DXEndpoint properties.
     * If there is no subscription, then this method returns an empty vector.
     * Otherwise, it creates a vector of events of the specified event type `E` and returns it.
     *
     * The events are ordered by @ref TimeSeriesEvent::getTime() "time" in the vector.
     *
     * <p>If there is a subscription, but the events have not arrived from the uplink data provider,
     * this method returns an empty vector.
     *
     * <p>Use @ref DXFeed::getTimeSeriesPromise() "getTimeSeriesPromise" method
     * if events need to be requested in the absence of subscription.
     *
     * <p>Note that this method does not work when DXEndpoint was created with
     * @ref DXEndpoint::Role::STREAM_FEED "STREAM_FEED" role (always returns an empty vector).
     *
     * <p>This method does not accept an instance of TimeSeriesSubscriptionSymbol as a `symbol`.
     * The later class is designed for use with DXFeedSubscription and to observe time-series subscription in
     * DXPublisher.
     *
     * <h3>Event flags and consistent snapshot</h3>
     *
     * This method returns a vector of events that are currently in the cache without any wait or delay,
     * and it <b>does not</b> guarantee that a consistent snapshot of events is returned.
     * See IndexedEvent documentation for details.
     * The @ref IndexedEvent::getEventFlags() "eventFlags" property of the events in the resulting vector
     * is always zero regardless. Use @ref DXFeed::getTimeSeriesPromise() "getTimeSeriesPromise" method
     * if a consistent snapshot of events needs to be requested.
     *
     * <p>Note that the resulting vector <em>should not</em> be used with DXPublisher::publishEvents() method, because
     * the latter expects events in a different order and with an appropriate flags set. See documentation on a specific
     * event class for details on how they should be published.
     *
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @param fromTime The time, inclusive, to request events from (see TimeSeriesEvent::getTime()).
     * @param toTime The time, inclusive, to request events to (see TimeSeriesEvent::getTime()).
     *               Use `std::numeric_limits<std::int64_t>::max()` or `LLONG_MAX` macro to retrieve events without an
     *               upper limit on time.
     * @return the vector of events or an empty vector if there is no subscription for the specified event type, symbol
     * and time range.
     */
    template <Derived<TimeSeriesEvent> E>
    std::vector<std::shared_ptr<E>> getTimeSeriesIfSubscribed(const SymbolWrapper &symbol, std::int64_t fromTime,
                                                              std::int64_t toTime) const {
        return convertEvents<EventType, E>(getTimeSeriesIfSubscribedImpl(E::TYPE, symbol, fromTime, toTime));
    }
 
    /**
     * Returns time series of events for the specified event type, symbol and a range of time if there is a
     * subscription for it. This method <b>does not</b> make any remote calls to the uplink data provider. It just
     * retrieves last received events from the local cache of this feed. The events are stored in the cache only if
     * there is some attached DXFeedSubscription that is subscribed to the corresponding event type, symbol and time.
     * The subscription can also be permanently defined using DXEndpoint properties.
     * If there is no subscription, then this method returns an empty vector.
     * Otherwise, it creates a vector of events of the specified event type `E` and returns it.
     *
     * The events are ordered by @ref TimeSeriesEvent::getTime() "time" in the vector.
     *
     * <p>If there is a subscription, but the events have not arrived from the uplink data provider,
     * this method returns an empty vector.
     *
     * <p>Use @ref DXFeed::getTimeSeriesPromise() "getTimeSeriesPromise" method
     * if events need to be requested in the absence of subscription.
     *
     * <p>Note that this method does not work when DXEndpoint was created with
     * @ref DXEndpoint::Role::STREAM_FEED "STREAM_FEED" role (always returns an empty vector).
     *
     * <p>This method does not accept an instance of TimeSeriesSubscriptionSymbol as a `symbol`.
     * The later class is designed for use with DXFeedSubscription and to observe time-series subscription in
     * DXPublisher.
     *
     * <h3>Event flags and consistent snapshot</h3>
     *
     * This method returns a vector of events that are currently in the cache without any wait or delay,
     * and it <b>does not</b> guarantee that a consistent snapshot of events is returned.
     * See IndexedEvent documentation for details.
     * The @ref IndexedEvent::getEventFlags() "eventFlags" property of the events in the resulting vector
     * is always zero regardless. Use @ref DXFeed::getTimeSeriesPromise() "getTimeSeriesPromise" method
     * if a consistent snapshot of events needs to be requested.
     *
     * <p>Note that the resulting vector <em>should not</em> be used with DXPublisher::publishEvents() method, because
     * the latter expects events in a different order and with an appropriate flags set. See documentation on a specific
     * event class for details on how they should be published.
     *
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @param fromTime The time, inclusive, to request events from (see TimeSeriesEvent::getTime()).
     * @param toTime The time, inclusive, to request events to (see TimeSeriesEvent::getTime()).
     * Use `std::chrono::milliseconds(std::numeric_limits<std::int64_t>::max())`
     * or `std::chrono::milliseconds(LLONG_MAX)` to retrieve events without an upper limit on time.
     * @return the vector of events or an empty vector if there is no subscription for the specified event type, symbol
     * and time range.
     */
    template <Derived<TimeSeriesEvent> E>
    std::vector<std::shared_ptr<E>> getTimeSeriesIfSubscribed(const SymbolWrapper &symbol,
                                                              std::chrono::milliseconds fromTime,
                                                              std::chrono::milliseconds toTime) const {
        return getTimeSeriesIfSubscribed<E>(symbol, fromTime.count(), toTime.count());
    }
 
    /**
     * Returns time series of events for the specified event type, symbol and a range of time (without an upper limit
     * on time) if there is a subscription for it.
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @param fromTime The time, inclusive, to request events from (see TimeSeriesEvent::getTime()).
     * @return the vector of events or an empty vector if there is no subscription for the specified event type, symbol
     * and time range.
     */
    template <Derived<TimeSeriesEvent> E>
    std::vector<std::shared_ptr<E>> getTimeSeriesIfSubscribed(const SymbolWrapper &symbol,
                                                              std::int64_t fromTime) const {
        return getTimeSeriesIfSubscribed<E>(symbol, fromTime, std::numeric_limits<std::int64_t>::max());
    }
 
    /**
     * Returns time series of events for the specified event type, symbol and a range of time (without an upper limit
     * on time) if there is a subscription for it.
     * @tparam E The type of event.
     * @param symbol The symbol.
     * @param fromTime The time, inclusive, to request events from (see TimeSeriesEvent::getTime()).
     * @return the vector of events or an empty vector if there is no subscription for the specified event type, symbol
     * and time range.
     */
    template <Derived<TimeSeriesEvent> E>
    std::vector<std::shared_ptr<E>> getTimeSeriesIfSubscribed(const SymbolWrapper &symbol,
                                                              std::chrono::milliseconds fromTime) const {
        return getTimeSeriesIfSubscribed<E>(symbol, fromTime.count());
    }
 
    std::string toString() const override;
};
 
DXFCPP_END_NAMESPACE
 
DXFCXX_DISABLE_MSC_WARNINGS_POP()