7     printf("//! [buffer count sample]\n");
12                 printf("OnNext:");  in __anon9fb0f4620102()
14                     printf(" %d", a);  in __anon9fb0f4620102()
16                 printf("\n");  in __anon9fb0f4620102()
18             [](){printf("OnCompleted\n");});  in __anon9fb0f4620302()
19     printf("//! [buffer count sample]\n");
23     printf("//! [buffer count+skip sample]\n");
28                 printf("OnNext:");  in __anon9fb0f4620402()
30                     printf(" %d", a);  in __anon9fb0f4620402()
32                 printf("\n");  in __anon9fb0f4620402()
34             [](){printf("OnCompleted\n");});  in __anon9fb0f4620602()
35     printf("//! [buffer count+skip sample]\n");
41     printf("//! [buffer period+skip+coordination sample]\n");
42     printf("[thread %s] Start task\n", get_pid().c_str());
47             printf("[thread %s] Interval OnNext: %ld\n", get_pid().c_str(), v);  in __anon9fb0f4620702()
56                 printf("[thread %s] OnNext:", get_pid().c_str());  in __anon9fb0f4620802()
58                     printf(" %ld", a);  in __anon9fb0f4620802()
60                 printf("\n");  in __anon9fb0f4620802()
62             [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});  in __anon9fb0f4620a02()
63     printf("[thread %s] Finish task\n", get_pid().c_str());
64     printf("//! [buffer period+skip+coordination sample]\n");
68     printf("//! [buffer period+skip sample]\n");
77                 printf("OnNext:");  in __anon9fb0f4620b02()
79                     printf(" %ld", a);  in __anon9fb0f4620b02()
81                 printf("\n");  in __anon9fb0f4620b02()
83             [](){printf("OnCompleted\n");});  in __anon9fb0f4620d02()
84     printf("//! [buffer period+skip sample]\n");
88     printf("//! [buffer period+skip overlapping sample]\n");
97                 printf("OnNext:");  in __anon9fb0f4620e02()
99                     printf(" %ld", a);  in __anon9fb0f4620e02()
101                 printf("\n");  in __anon9fb0f4620e02()
103             [](){printf("OnCompleted\n");});  in __anon9fb0f4621002()
104     printf("//! [buffer period+skip overlapping sample]\n");
108     printf("//! [buffer period+skip empty sample]\n");
116                 printf("OnNext:");  in __anon9fb0f4621102()
118                     printf(" %ld", a);  in __anon9fb0f4621102()
120                 printf("\n");  in __anon9fb0f4621102()
122             [](){printf("OnCompleted\n");});  in __anon9fb0f4621302()
123     printf("//! [buffer period+skip empty sample]\n");
127     printf("//! [buffer period+coordination sample]\n");
135                 printf("OnNext:");  in __anon9fb0f4621402()
137                     printf(" %ld", a);  in __anon9fb0f4621402()
139                 printf("\n");  in __anon9fb0f4621402()
141             [](){printf("OnCompleted\n");});  in __anon9fb0f4621602()
142     printf("//! [buffer period+coordination sample]\n");
146     printf("//! [buffer period sample]\n");
153                 printf("OnNext:");  in __anon9fb0f4621702()
155                     printf(" %ld", a);  in __anon9fb0f4621702()
157                 printf("\n");  in __anon9fb0f4621702()
159             [](){printf("OnCompleted\n");});  in __anon9fb0f4621902()
160     printf("//! [buffer period sample]\n");
164     printf("//! [buffer period+count+coordination sample]\n");
174                 printf("OnNext:");  in __anon9fb0f4621a02()
176                     printf(" %ld", a);  in __anon9fb0f4621a02()
178                 printf("\n");  in __anon9fb0f4621a02()
180             [](){printf("OnCompleted\n");});  in __anon9fb0f4621c02()
181     printf("//! [buffer period+count+coordination sample]\n");
185     printf("//! [buffer period+count sample]\n");
194                 printf("OnNext:");  in __anon9fb0f4621d02()
196                     printf(" %ld", a);  in __anon9fb0f4621d02()
198                 printf("\n");  in __anon9fb0f4621d02()
200             [](){printf("OnCompleted\n");});  in __anon9fb0f4621f02()
201     printf("//! [buffer period+count sample]\n");