execution: just (#1384)

make-sender, basic-sender, basic-operation, impls-for

Author: yohhoy

reference/execution/execution.md

@@ -99,7 +99,7 @@ namespace std::execution {
 
 | 名前 | 説明 | 対応バージョン |
 |------|------|----------------|
-| [`execution::just`](execution/just.md.nolink) | 値を送信するSender (customization point object) | C++26 |
+| [`execution::just`](execution/just.md) | 値を送信するSender (customization point object) | C++26 |
 | [`execution::just_error`](execution/just_error.md.nolink) | エラーを送信するSender (customization point object) | C++26 |
 | [`execution::just_stopped`](execution/just_stopped.md.nolink) | 停止を送信するSender (customization point object) | C++26 |
 | [`execution::read_env`](execution/read_env.md.nolink) | Receiver環境から構築されるSender (customization point object) | C++26 |

reference/execution/execution/basic-operation.md

@@ -0,0 +1,149 @@
+# basic-operation
+* execution[meta header]
+* class template[meta id-type]
+* std::execution[meta namespace]
+* cpp26[meta cpp]
+
+```cpp
+namespace std::execution {
+  template<class Sndr, class Rcvr>
+    requires valid-specialization<state-type, Sndr, Rcvr> &&
+             valid-specialization<connect-all-result, Sndr, Rcvr>
+  struct basic-operation : basic-state<Sndr, Rcvr> {  // exposition only
+    using operation_state_concept = operation_state_t;
+    using tag-t = tag_of_t<Sndr>;                     // exposition only
+
+    connect-all-result<Sndr, Rcvr> inner-ops;         // exposition only
+
+    basic-operation(Sndr&& sndr, Rcvr&& rcvr) noexcept(see below)  // exposition only
+      : basic-state<Sndr, Rcvr>(std::forward<Sndr>(sndr), std::move(rcvr)),
+        inner-ops(connect-all(this, std::forward<Sndr>(sndr), indices-for<Sndr>()))
+    {}
+
+    void start() & noexcept {
+      auto& [...ops] = inner-ops;
+      impls-for<tag-t>::start(this->state, this->rcvr, ops...);
+    }
+  };
+
+  template<class Sndr, class Rcvr>
+  struct basic-state {             // exposition only
+    basic-state(Sndr&& sndr, Rcvr&& rcvr) noexcept(see below)
+      : rcvr(std::move(rcvr))
+      , state(impls-for<tag_of_t<Sndr>>::get-state(std::forward<Sndr>(sndr), rcvr)) { }
+
+    Rcvr rcvr;                     // exposition only
+    state-type<Sndr, Rcvr> state;  // exposition only
+  };
+}
+```
+* operation_state_t[link operation_state.md]
+* tag_of_t[link tag_of_t.md.nolink]
+* impls-for[link impls-for.md]
+* see below[italic]
+
+## 概要
+`basic-operation`および`basic-state`は、Senderアルゴリズム動作仕様定義で用いられる説明専用のクラステンプレートである。
+
+`basic-operation<Sndr, Rcvr>`は[`operation_state`](operation_state.md)のモデルであり、[Senderアルゴリズム](basic-sender.md)と[Recevier](receiver.md)の[接続(connect)](connect.md)結果型として利用される。
+
+- `rcvr` : 接続先Receiverオブジェクトを保持。Senderアルゴリズム同士を連結する場合は、親Senderアルゴリズム側の[Receiver](receiver.md)が該当する。
+- `state` : Senderアルゴリズム構築時の引数リストを保持。（[`impls-for`](impls-for.md)でカスタマイズ可能）
+- `inner-ops` : 子SenderリストとSenderアルゴリズムとの接続結果[Operation State](operation_state.md)リストを保持。Senderファクトリでは0個、Senderアダプタでは通常1個の子Senderと接続される。
+
+
+## クラス仕様
+`basic-operation`コンストラクタ`noexcept`節の式は下記の通り。
+
+```cpp
+is_nothrow_constructible_v<basic-state<Self, Rcvr>, Self, Rcvr> &&
+noexcept(connect-all(this, std::forward<Sndr>(sndr), indices-for<Sndr>()))
+```
+* is_nothrow_constructible_v[link /reference/type_traits/is_nothrow_constructible.md]
+
+`basic-state`コンストラクタ`noexcept`節の式は下記の通り。
+
+```cpp
+is_nothrow_move_constructible_v<Rcvr> &&
+nothrow-callable<decltype(impls-for<tag_of_t<Sndr>>::get-state), Sndr, Rcvr&> &&
+(same_as<state-type<Sndr, Rcvr>, get-state-result> ||
+ is_nothrow_constructible_v<state-type<Sndr, Rcvr>, get-state-result>)
+```
+* impls-for[link impls-for.md]
+* tag_of_t[link tag_of_t.md.nolink]
+* is_nothrow_move_constructible_v[link /reference/type_traits/is_nothrow_move_constructible.md]
+* is_nothrow_constructible_v[link /reference/type_traits/is_nothrow_constructible.md]
+
+ここで、説明用の型`get-state-result`は下記の通り定義される。
+
+```cpp
+call-result-t<decltype(impls-for<tag_of_t<Sndr>>::get-state), Sndr, Rcvr&>.
+```
+* impls-for[link impls-for.md]
+* tag_of_t[link tag_of_t.md.nolink]
+
+
+## 説明専用エンティティ
+
+```cpp
+template<template<class...> class T, class... Args>
+concept valid-specialization =  // exposition only
+  requires { typename T<Args...>; };
+
+template<class Sndr, class Rcvr>  // exposition only
+using state-type = decay_t<call-result-t<
+  decltype(impls-for<tag_of_t<Sndr>>::get-state), Sndr, Rcvr&>>;
+
+constexpr auto connect-all = see below;  // exposition only
+
+template<class Sndr, class Rcvr>
+using connect-all-result = call-result-t<  // exposition only
+  decltype(connect-all), basic-state<Sndr, Rcvr>*, Sndr, indices-for<Sndr>>;
+
+template<class Sndr>
+using indices-for = remove_reference_t<Sndr>::indices-for;  // exposition only 
+```
+* impls-for[link impls-for.md]
+* tag_of_t[link tag_of_t.md.nolink]
+* decay_t[link /reference/type_traits/decay.md]
+* remove_reference_t[link /reference/type_traits/remove_reference.md]
+* see below[italic]
+
+説明専用の定数`connect-all`は、下記ラムダ式と等価な関数呼び出し可能なオブジェクトとして初期化される。
+
+- 全ての子Sender`child`とSenderアルゴリズム`sndr`の[Receiver](basic-receiver.md)を[接続(connect)](connec.md)し、結果の[Operation State](operation_state.md)リストを[`product-type`](product-type.md.nolink)型にまとめて返す。
+
+```cpp
+[]<class Sndr, class Rcvr, size_t... Is>(
+  basic-state<Sndr, Rcvr>* op, Sndr&& sndr, index_sequence<Is...>) noexcept(see below)
+    -> decltype(auto) {
+    auto& [_, data, ...child] = sndr;
+    return product-type{connect(
+      std::forward_like<Sndr>(child),
+      basic-receiver<Sndr, Rcvr, integral_constant<size_t, Is>>{op})...};
+  }
+```
+* index_sequence[link /reference/utility/index_sequence.md]
+* product-type[link product-type.md.nolink]
+* connect[link connect.md]
+* basic-receiver[link basic-receiver.md.nolink]
+* integral_constant[link /reference/type_traits/integral_constant.md]
+* see below[italic]
+
+- テンプレートパラメータ制約 : ラムダ式中の`return`文の式が適格であること。
+- ラムダ式中の`return`文の式が例外送出する可能性がある場合は、`noexcept(false)`となる。そうでなければ、`noexcept(true)`となる。
+
+
+## バージョン
+### 言語
+- C++26
+
+
+## 関連項目
+- [`basic-sender`](basic-sender.md)
+- [`basic-receiver`](basic-receiver.md.nolink)
+- [`execution::operation_state`](operation_state.md)
+
+
+## 参照
+- [P2300R10 `std::execution`](https://www.open-std.org/jtc1/sc22/wg21/docs/papers/2024/p2300r10.html)

reference/execution/execution/basic-sender.md

@@ -0,0 +1,91 @@
+# basic-sender
+* execution[meta header]
+* class template[meta id-type]
+* std::execution[meta namespace]
+* cpp26[meta cpp]
+
+```cpp
+namespace std::execution {
+  template<class Tag, class Data, class... Child>
+  struct basic-sender : product-type<Tag, Data, Child...> {  // exposition only
+    using sender_concept = sender_t;
+    using indices-for = index_sequence_for<Child...>;        // exposition only
+
+    decltype(auto) get_env() const noexcept {
+      auto& [_, data, ...child] = *this;
+      return impls-for<Tag>::get-attrs(data, child...);
+    }
+
+    template<decays-to<basic-sender> Self, receiver Rcvr>
+    auto connect(this Self&& self, Rcvr rcvr) noexcept(see below)
+      -> basic-operation<Self, Rcvr> {
+      return {std::forward<Self>(self), std::move(rcvr)};
+    }
+
+    template<decays-to<basic-sender> Self, class Env>
+    auto get_completion_signatures(this Self&& self, Env&& env) noexcept
+      -> completion-signatures-for<Self, Env> {
+      return {};
+    }
+  };
+}
+```
+* product-type[link product-type.md.nolink]
+* sender_t[link sender.md]
+* index_sequence_for[link /reference/utility/index_sequence_for.md]
+* impls-for[link impls-for.md]
+* receiver[link receiver.md]
+* basic-operation[link basic-operation.md]
+* this Self[link /lang/cpp23/deducing_this.md.nolink]
+* see below[italic]
+
+## 概要
+`basic-sender`は、Senderアルゴリズム動作仕様定義で用いられる説明専用のクラステンプレートである。
+
+`basic-sender<Tag, Data, Child...>`は[`sender`](sender.md)のモデルであり、[Senderアルゴリズム構築](make-sender.md)の結果型として利用される。
+
+- `Tag` : [Senderタグ](tag_of_t.md.nolink)（例：[`just`](just.md), [`then`](then.md.nolink)）
+- `Data` : Senderアルゴリズムに指定された追加の引数。複数個の引数は[`product-type`](product-type.md.nolink)型を用いて単一値として保持する。
+- `Child` : 子Senderのリスト。Senderファクトリでは0個、Senderアダプタでは通常1個の子Senderを保持する。
+
+
+## クラス仕様
+`basic-sender`の特殊化が集成体となるか否かは未規定である。
+`basic-sender`型の式は[構造化束縛](/lang/cpp17/structured_bindings.md)における初期化子として利用できる。
+
+`basic-sender::connect`メンバ関数`noexcept`節の式は下記の通り。
+
+```cpp
+is_nothrow_constructible_v<basic-operation<Self, Rcvr>, Self, Rcvr>
+```
+* is_nothrow_constructible_v[link /reference/type_traits/is_nothrow_constructible.md]
+* basic-operation[link basic-operation.md]
+
+説明専用のエイリアステンプレート`completion-signatures-for`は、下記の通り定義される。
+
+```
+template<class Sndr, class Env>
+using completion-signatures-for = see below;  // exposition only
+```
+* see below[italic]
+
+説明用の`sndr`を`decltype((sndr))`が`Sndr`型となる式、`rcvr`を[`sender_in`](sender_in.md)`<Sndr, Env> == true`となる[環境](../queryable.md)`Env`に関連付けられた[`Receiver`](receiver.md)とする。
+
+`completion-signatures-for<Sndr, Env>`は[`completion_signatures`](completion_signatures.md)の特殊化であり、そのテンプレート引数は `sndr`と`rcvr`との[接続(connect)](connect.md)結果[Operation State](operation_state.md)を[開始(start)](start.md)して得られる可能性のある結果の完了シグネチャ集合となる。
+
+[`sender_in`](sender_in.md)`<Sndr, Env> == false`となる場合、`completion-signatures-for<Sndr, Env>`は[`completion_signatures`](completion_signatures.md)の特殊化ではない別の型となる。
+ 処理系（標準ライブラリ実装者）は、この型を用いてユーザにエラー理由を通知することが推奨される。
+
+
+## バージョン
+### 言語
+- C++26
+
+
+## 関連項目
+- [`make-sender`](make-sender.md)
+- [`execution::sender`](sender.md)
+
+
+## 参照
+- [P2300R10 `std::execution`](https://www.open-std.org/jtc1/sc22/wg21/docs/papers/2024/p2300r10.html)

reference/execution/execution/connect.md

@@ -209,7 +209,7 @@ int main()
 * ex::connect[color ff0000]
 * ex::receiver_t[link receiver.md]
 * ex::sender[link sender.md]
-* ex::just[link just.md.nolink]
+* ex::just[link just.md]
 * ex::operation_state[link operation_state.md]
 * ex::start[link start.md]
 

reference/execution/execution/error_types_of_t.md

@@ -52,7 +52,7 @@ int main()
 ```
 * ex::error_types_of_t[color ff0000]
 * ex::sender[link sender.md]
-* ex::just[link just.md.nolink]
+* ex::just[link just.md]
 * ex::just_error[link just_error.md.nolink]
 
 ### 出力

reference/execution/execution/get_completion_signatures.md

@@ -68,7 +68,7 @@ int main()
 ```
 * ex::get_completion_signatures[color ff0000]
 * ex::sender[link sender.md]
-* ex::just[link just.md.nolink]
+* ex::just[link just.md]
 * ex::completion_signatures[link completion_signatures.md]
 * ex::env<>[link env.md]
 * ex::set_value_t[link set_value.md]

reference/execution/execution/get_env.md

@@ -52,7 +52,7 @@ int main()
 ```
 * ex::get_env[color ff0000]
 * ex::sender[link sender.md]
-* ex::just[link just.md.nolink]
+* ex::just[link just.md]
 
 ### 出力
 ```