Class StreamHandle

src/fl/net/http/stream_transport.h:23–49

Handle for ASYNC_STREAM calls Provides onData() for intermediate updates, plus then()/catch_() for final result

/// Handle for ASYNC_STREAM calls
/// Provides onData() for intermediate updates, plus then()/catch_() for final result
class StreamHandle {
public:
    StreamHandle() FL_NOEXCEPT = default;

    /// Register callback for intermediate stream data
    StreamHandle& onData(fl::function<void(const fl::json&)> cb);

    /// Register callback for final result
    StreamHandle& then(fl::function<void(const fl::json&)> cb);

    /// Register callback for errors
    StreamHandle& catch_(fl::function<void(const fl::task::Error&)> cb);

    /// Access the underlying promise
    fl::task::Promise<fl::json>& promise();

    /// Check if handle is valid
    bool valid() const;

private:
    friend class HttpStreamTransport;
    StreamHandle(fl::task::Promise<fl::json> p,
                 fl::shared_ptr<fl::function<void(const fl::json&)>> updateCb);

    fl::task::Promise<fl::json> mPromise;
    fl::shared_ptr<fl::function<void(const fl::json&)>> mUpdateCallback;
};

/// Base class for HTTP streaming transport
/// Implements RequestSource and ResponseSink for Remote class