Iros
 
Loading...
Searching...
No Matches
ensure_started.h File Reference
#include "di/assert/assert_bool.h"
#include "di/container/allocator/allocator.h"
#include "di/container/allocator/fallible_allocator.h"
#include "di/container/allocator/infallible_allocator.h"
#include "di/execution/concepts/receiver_of.h"
#include "di/execution/concepts/sender_in.h"
#include "di/execution/interface/connect.h"
#include "di/execution/interface/get_env.h"
#include "di/execution/interface/start.h"
#include "di/execution/meta/completion_signatures_of.h"
#include "di/execution/meta/connect_result.h"
#include "di/execution/meta/decayed_tuple.h"
#include "di/execution/meta/env_of.h"
#include "di/execution/meta/make_completion_signatures.h"
#include "di/execution/meta/stop_token_of.h"
#include "di/execution/query/get_stop_token.h"
#include "di/execution/query/make_env.h"
#include "di/execution/receiver/set_error.h"
#include "di/execution/receiver/set_stopped.h"
#include "di/execution/receiver/set_value.h"
#include "di/execution/types/empty_env.h"
#include "di/function/container/prelude.h"
#include "di/meta/algorithm.h"
#include "di/meta/core.h"
#include "di/meta/util.h"
#include "di/platform/compiler.h"
#include "di/sync/atomic.h"
#include "di/sync/memory_order.h"
#include "di/sync/stop_token/in_place_stop_source.h"
#include "di/sync/stop_token/in_place_stop_token.h"
#include "di/types/in_place.h"
#include "di/types/integers.h"
#include "di/types/prelude.h"
#include "di/util/addressof.h"
#include "di/util/exchange.h"
#include "di/util/immovable.h"
#include "di/vocab/optional/optional_forward_declaration.h"
#include "di/vocab/tuple/tuple.h"

Go to the source code of this file.

Classes

struct  di::execution::ensure_started_ns::StopCallbackFunction
 
struct  di::execution::ensure_started_ns::SharedReceiverT< SharedState >
 
struct  di::execution::ensure_started_ns::SharedReceiverT< SharedState >::Type
 
struct  di::execution::ensure_started_ns::SharedStateT< Send, SenderAttr, Alloc >
 
struct  di::execution::ensure_started_ns::SharedStateT< Send, SenderAttr, Alloc >::Type
 
struct  di::execution::ensure_started_ns::OperationStateT< Send, Rec, SenderAttr, Alloc >
 
struct  di::execution::ensure_started_ns::OperationStateT< Send, Rec, SenderAttr, Alloc >::Type
 
struct  di::execution::ensure_started_ns::SenderT< Send, Alloc >
 
struct  di::execution::ensure_started_ns::SenderT< Send, Alloc >::Type
 
struct  di::execution::ensure_started_ns::Function
 

Namespaces

namespace  di
 
namespace  di::execution
 
namespace  di::execution::ensure_started_ns
 

Typedefs

using di::execution::ensure_started_ns::StopSource = sync::InPlaceStopSource
 
using di::execution::ensure_started_ns::StopToken = sync::InPlaceStopToken
 
template<typename T>
using di::execution::ensure_started_ns::DecayedRValue = meta::Decay<T>&&
 
using di::execution::ensure_started_ns::Env = MakeEnv<EmptyEnv, With<Tag<get_stop_token>, StopToken>>
 
template<typename... Values>
using di::execution::ensure_started_ns::SigSetValue = CompletionSignatures<SetValue(meta::Decay<Values>&&...)>
 
template<typename E>
using di::execution::ensure_started_ns::SigSetError = CompletionSignatures<SetError(meta::Decay<E>&&)>
 
template<typename Seq>
using di::execution::ensure_started_ns::Sigs = meta::MakeCompletionSignatures<Seq, Env, CompletionSignatures<>, SigSetValue, SigSetError>
 
template<typename SharedState>
using di::execution::ensure_started_ns::SharedReceiver = meta::Type<SharedReceiverT<SharedState>>
 
template<typename Send, typename SenderAttr, typename Alloc>
using di::execution::ensure_started_ns::SharedState = meta::Type<SharedStateT<Send, meta::Decay<SenderAttr>, meta::Decay<Alloc>>>
 
template<typename Send, typename Rec, typename SenderAttr, typename Alloc>
using di::execution::ensure_started_ns::OperationState = meta::Type<OperationStateT<Send, Rec, meta::Decay<SenderAttr>, Alloc>>
 
template<typename Send, typename Alloc>
using di::execution::ensure_started_ns::Sender = meta::Type<SenderT<Send, meta::Decay<Alloc>>>
 

Variables

constexpr auto di::execution::ensure_started = ensure_started_ns::Function {}
 Eagerly start a sender.