12
12
#include < atomic>
13
13
#include < iterator>
14
14
#include < type_traits>
15
- #include < experimental /coroutine>
15
+ #include < cppcoro /coroutine.hpp >
16
16
#include < functional>
17
17
#include < cassert>
18
18
@@ -45,7 +45,7 @@ namespace cppcoro
45
45
async_generator_promise_base (const async_generator_promise_base& other) = delete ;
46
46
async_generator_promise_base& operator =(const async_generator_promise_base& other) = delete ;
47
47
48
- std::experimental ::suspend_always initial_suspend () const noexcept
48
+ cppcoro ::suspend_always initial_suspend () const noexcept
49
49
{
50
50
return {};
51
51
}
@@ -89,7 +89,7 @@ namespace cppcoro
89
89
90
90
std::exception_ptr m_exception;
91
91
92
- std::experimental ::coroutine_handle<> m_consumerCoroutine;
92
+ cppcoro ::coroutine_handle<> m_consumerCoroutine;
93
93
94
94
protected:
95
95
@@ -100,7 +100,7 @@ namespace cppcoro
100
100
{
101
101
public:
102
102
103
- async_generator_yield_operation (std::experimental ::coroutine_handle<> consumer) noexcept
103
+ async_generator_yield_operation (cppcoro ::coroutine_handle<> consumer) noexcept
104
104
: m_consumer(consumer)
105
105
{}
106
106
@@ -109,8 +109,8 @@ namespace cppcoro
109
109
return false ;
110
110
}
111
111
112
- std::experimental ::coroutine_handle<>
113
- await_suspend ([[maybe_unused]] std::experimental ::coroutine_handle<> producer) noexcept
112
+ cppcoro ::coroutine_handle<>
113
+ await_suspend ([[maybe_unused]] cppcoro ::coroutine_handle<> producer) noexcept
114
114
{
115
115
return m_consumer;
116
116
}
@@ -119,7 +119,7 @@ namespace cppcoro
119
119
120
120
private:
121
121
122
- std::experimental ::coroutine_handle<> m_consumer;
122
+ cppcoro ::coroutine_handle<> m_consumer;
123
123
124
124
};
125
125
@@ -145,7 +145,7 @@ namespace cppcoro
145
145
146
146
async_generator_advance_operation (
147
147
async_generator_promise_base& promise,
148
- std::experimental ::coroutine_handle<> producerCoroutine) noexcept
148
+ cppcoro ::coroutine_handle<> producerCoroutine) noexcept
149
149
: m_promise(std::addressof(promise))
150
150
, m_producerCoroutine(producerCoroutine)
151
151
{
@@ -155,8 +155,8 @@ namespace cppcoro
155
155
156
156
bool await_ready () const noexcept { return false ; }
157
157
158
- std::experimental ::coroutine_handle<>
159
- await_suspend (std::experimental ::coroutine_handle<> consumerCoroutine) noexcept
158
+ cppcoro ::coroutine_handle<>
159
+ await_suspend (cppcoro ::coroutine_handle<> consumerCoroutine) noexcept
160
160
{
161
161
m_promise->m_consumerCoroutine = consumerCoroutine;
162
162
return m_producerCoroutine;
@@ -165,7 +165,7 @@ namespace cppcoro
165
165
protected:
166
166
167
167
async_generator_promise_base* m_promise;
168
- std::experimental ::coroutine_handle<> m_producerCoroutine;
168
+ cppcoro ::coroutine_handle<> m_producerCoroutine;
169
169
170
170
};
171
171
@@ -242,7 +242,7 @@ namespace cppcoro
242
242
class async_generator_iterator final
243
243
{
244
244
using promise_type = async_generator_promise<T>;
245
- using handle_type = std::experimental ::coroutine_handle<promise_type>;
245
+ using handle_type = cppcoro ::coroutine_handle<promise_type>;
246
246
247
247
public:
248
248
@@ -307,7 +307,7 @@ namespace cppcoro
307
307
class async_generator_begin_operation final : public async_generator_advance_operation
308
308
{
309
309
using promise_type = async_generator_promise<T>;
310
- using handle_type = std::experimental ::coroutine_handle<promise_type>;
310
+ using handle_type = cppcoro ::coroutine_handle<promise_type>;
311
311
312
312
public:
313
313
@@ -358,7 +358,7 @@ namespace cppcoro
358
358
{}
359
359
360
360
explicit async_generator (promise_type& promise) noexcept
361
- : m_coroutine (std::experimental ::coroutine_handle<promise_type>::from_promise (promise))
361
+ : m_coroutine (cppcoro ::coroutine_handle<promise_type>::from_promise (promise))
362
362
{}
363
363
364
364
async_generator (async_generator&& other) noexcept
@@ -408,7 +408,7 @@ namespace cppcoro
408
408
409
409
private:
410
410
411
- std::experimental ::coroutine_handle<promise_type> m_coroutine;
411
+ cppcoro ::coroutine_handle<promise_type> m_coroutine;
412
412
413
413
};
414
414
@@ -451,7 +451,7 @@ namespace cppcoro
451
451
async_generator_promise_base (const async_generator_promise_base& other) = delete ;
452
452
async_generator_promise_base& operator =(const async_generator_promise_base& other) = delete ;
453
453
454
- std::experimental ::suspend_always initial_suspend () const noexcept
454
+ cppcoro ::suspend_always initial_suspend () const noexcept
455
455
{
456
456
return {};
457
457
}
@@ -556,7 +556,7 @@ namespace cppcoro
556
556
557
557
std::exception_ptr m_exception;
558
558
559
- std::experimental ::coroutine_handle<> m_consumerCoroutine;
559
+ cppcoro ::coroutine_handle<> m_consumerCoroutine;
560
560
561
561
protected:
562
562
@@ -579,7 +579,7 @@ namespace cppcoro
579
579
return m_initialState == state::value_not_ready_consumer_suspended;
580
580
}
581
581
582
- bool await_suspend (std::experimental ::coroutine_handle<> producer) noexcept ;
582
+ bool await_suspend (cppcoro ::coroutine_handle<> producer) noexcept ;
583
583
584
584
void await_resume () noexcept {}
585
585
@@ -625,7 +625,7 @@ namespace cppcoro
625
625
}
626
626
627
627
inline bool async_generator_yield_operation::await_suspend (
628
- std::experimental ::coroutine_handle<> producer) noexcept
628
+ cppcoro ::coroutine_handle<> producer) noexcept
629
629
{
630
630
state currentState = m_initialState;
631
631
if (currentState == state::value_not_ready_consumer_active)
@@ -711,7 +711,7 @@ namespace cppcoro
711
711
712
712
async_generator_advance_operation (
713
713
async_generator_promise_base& promise,
714
- std::experimental ::coroutine_handle<> producerCoroutine) noexcept
714
+ cppcoro ::coroutine_handle<> producerCoroutine) noexcept
715
715
: m_promise(std::addressof(promise))
716
716
, m_producerCoroutine(producerCoroutine)
717
717
{
@@ -740,7 +740,7 @@ namespace cppcoro
740
740
return m_initialState == state::value_ready_producer_suspended;
741
741
}
742
742
743
- bool await_suspend (std::experimental ::coroutine_handle<> consumerCoroutine) noexcept
743
+ bool await_suspend (cppcoro ::coroutine_handle<> consumerCoroutine) noexcept
744
744
{
745
745
m_promise->m_consumerCoroutine = consumerCoroutine;
746
746
@@ -791,7 +791,7 @@ namespace cppcoro
791
791
protected:
792
792
793
793
async_generator_promise_base* m_promise;
794
- std::experimental ::coroutine_handle<> m_producerCoroutine;
794
+ cppcoro ::coroutine_handle<> m_producerCoroutine;
795
795
796
796
private:
797
797
@@ -872,7 +872,7 @@ namespace cppcoro
872
872
class async_generator_iterator final
873
873
{
874
874
using promise_type = async_generator_promise<T>;
875
- using handle_type = std::experimental ::coroutine_handle<promise_type>;
875
+ using handle_type = cppcoro ::coroutine_handle<promise_type>;
876
876
877
877
public:
878
878
@@ -937,7 +937,7 @@ namespace cppcoro
937
937
class async_generator_begin_operation final : public async_generator_advance_operation
938
938
{
939
939
using promise_type = async_generator_promise<T>;
940
- using handle_type = std::experimental ::coroutine_handle<promise_type>;
940
+ using handle_type = cppcoro ::coroutine_handle<promise_type>;
941
941
942
942
public:
943
943
@@ -988,7 +988,7 @@ namespace cppcoro
988
988
{}
989
989
990
990
explicit async_generator (promise_type& promise) noexcept
991
- : m_coroutine(std::experimental ::coroutine_handle<promise_type>::from_promise(promise))
991
+ : m_coroutine(cppcoro ::coroutine_handle<promise_type>::from_promise(promise))
992
992
{}
993
993
994
994
async_generator (async_generator&& other) noexcept
@@ -1041,7 +1041,7 @@ namespace cppcoro
1041
1041
1042
1042
private:
1043
1043
1044
- std::experimental ::coroutine_handle<promise_type> m_coroutine;
1044
+ cppcoro ::coroutine_handle<promise_type> m_coroutine;
1045
1045
1046
1046
};
1047
1047
0 commit comments