MCPcopy Create free account
hub / github.com/AlexInLog/ReactivePlusPlus / create

Function create

src/rpp/rpp/sources/create.hpp:60–63  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

58 */
59 template<constraint::decayed_type Type, constraint::on_subscribe<Type> OnSubscribe>
60 auto create(OnSubscribe&& on_subscribe)
61 {
62 return create_observable<Type, std::decay_t<OnSubscribe>>{std::forward<OnSubscribe>(on_subscribe)};
63 }
64
65 /**
66 * @brief Construct observable specialized with passed callback function. Most easiesest way to construct observable "on the fly" via lambda and etc.

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected