resolve printf errors on clang

8 files changed, 53 insertions, 53 deletions

diff --git a/Rx/v2/examples/doxygen/buffer.cpp b/Rx/v2/examples/doxygen/buffer.cpp
index 9a5d0b0..e88c2ed 100644
--- a/Rx/v2/examples/doxygen/buffer.cpp
+++ b/Rx/v2/examples/doxygen/buffer.cpp
@@ -44,7 +44,7 @@ SCENARIO("buffer period+skip+coordination sample"){
     auto skip = std::chrono::milliseconds(6);
     auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::milliseconds(1), std::chrono::milliseconds(2)).
         map([](long v){
-            printf("[thread %s] Interval OnNext: %d\n", get_pid().c_str(), v);
+            printf("[thread %s] Interval OnNext: %ld\n", get_pid().c_str(), v);
             return v;
         }).
         take(7).
@@ -55,7 +55,7 @@ SCENARIO("buffer period+skip+coordination sample"){
             [](std::vector<long> v){
                 printf("[thread %s] OnNext:", get_pid().c_str());
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
@@ -76,7 +76,7 @@ SCENARIO("buffer period+skip sample"){
             [](std::vector<long> v){
                 printf("OnNext:");
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
@@ -96,7 +96,7 @@ SCENARIO("buffer period+skip overlapping sample"){
             [](std::vector<long> v){
                 printf("OnNext:");
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
@@ -115,7 +115,7 @@ SCENARIO("buffer period+skip empty sample"){
             [](std::vector<long> v){
                 printf("OnNext:");
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
@@ -134,7 +134,7 @@ SCENARIO("buffer period+coordination sample"){
             [](std::vector<long> v){
                 printf("OnNext:");
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
@@ -152,7 +152,7 @@ SCENARIO("buffer period sample"){
             [](std::vector<long> v){
                 printf("OnNext:");
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
@@ -174,7 +174,7 @@ SCENARIO("buffer period+count+coordination sample"){
             [start](std::vector<long> v){
                 printf("OnNext:");
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
@@ -195,7 +195,7 @@ SCENARIO("buffer period+count sample"){
             [start](std::vector<long> v){
                 printf("OnNext:");
                 std::for_each(v.begin(), v.end(), [](long a){
-                    printf(" %d", a);
+                    printf(" %ld", a);
                 });
                 printf("\n");
             },
diff --git a/Rx/v2/examples/doxygen/concat_map.cpp b/Rx/v2/examples/doxygen/concat_map.cpp
index 70664e0..957665f 100644
--- a/Rx/v2/examples/doxygen/concat_map.cpp
+++ b/Rx/v2/examples/doxygen/concat_map.cpp
@@ -17,7 +17,7 @@ SCENARIO("concat_map sample"){
             });
     values.
         subscribe(
-            [](std::tuple<int, long> v){printf("OnNext: %d - %d\n", std::get<0>(v), std::get<1>(v));},
+            [](std::tuple<int, long> v){printf("OnNext: %d - %ld\n", std::get<0>(v), std::get<1>(v));},
             [](){printf("OnCompleted\n");});
     printf("//! [concat_map sample]\n");
 }
@@ -36,14 +36,14 @@ SCENARIO("threaded concat_map sample"){
                     take(3);
             },
             [](int v_main, long v_sub){
-                printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %d)\n", get_pid().c_str(), v_main, v_sub);
+                printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %ld)\n", get_pid().c_str(), v_main, v_sub);
                 return std::make_tuple(v_main, v_sub);
             },
             rxcpp::observe_on_new_thread());
     values.
         as_blocking().
         subscribe(
-            [](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %d\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v));},
+            [](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v));},
             [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
     printf("[thread %s] Finish task\n", get_pid().c_str());
     printf("//! [threaded concat_map sample]\n");
diff --git a/Rx/v2/examples/doxygen/flat_map.cpp b/Rx/v2/examples/doxygen/flat_map.cpp
index 21db657..0c88cbe 100644
--- a/Rx/v2/examples/doxygen/flat_map.cpp
+++ b/Rx/v2/examples/doxygen/flat_map.cpp
@@ -17,7 +17,7 @@ SCENARIO("flat_map sample"){
             });
     values.
         subscribe(
-            [](std::tuple<int, long> v){printf("OnNext: %d - %d\n", std::get<0>(v), std::get<1>(v));},
+            [](std::tuple<int, long> v){printf("OnNext: %d - %ld\n", std::get<0>(v), std::get<1>(v));},
             [](){printf("OnCompleted\n");});
     printf("//! [flat_map sample]\n");
 }
@@ -43,7 +43,7 @@ SCENARIO("threaded flat_map sample"){
     values.
         as_blocking().
         subscribe(
-            [](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %d\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v));},
+            [](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0>(v), std::get<1>(v));},
             [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
     printf("[thread %s] Finish task\n", get_pid().c_str());
     printf("//! [threaded flat_map sample]\n");
diff --git a/Rx/v2/examples/doxygen/publish.cpp b/Rx/v2/examples/doxygen/publish.cpp
index 700fa89..d34e991 100644
--- a/Rx/v2/examples/doxygen/publish.cpp
+++ b/Rx/v2/examples/doxygen/publish.cpp
@@ -11,24 +11,24 @@ SCENARIO("publish_synchronized sample"){
 
     // Subscribe from the beginning
     values.subscribe(
-        [](long v){printf("[1] OnNext: %d\n", v);},
+        [](long v){printf("[1] OnNext: %ld\n", v);},
         [](){printf("[1] OnCompleted\n");});
-    
+
     // Another subscription from the beginning
     values.subscribe(
-        [](long v){printf("[2] OnNext: %d\n", v);},
+        [](long v){printf("[2] OnNext: %ld\n", v);},
         [](){printf("[2] OnCompleted\n");});
 
     // Start emitting
     values.connect();
-    
+
     // Wait before subscribing
     rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){
         values.subscribe(
-            [](long v){printf("[3] OnNext: %d\n", v);},
+            [](long v){printf("[3] OnNext: %ld\n", v);},
             [](){printf("[3] OnCompleted\n");});
     });
-    
+
     // Add blocking subscription to see results
     values.as_blocking().subscribe();
     printf("//! [publish_synchronized sample]\n");
@@ -42,24 +42,24 @@ SCENARIO("publish subject sample"){
 
     // Subscribe from the beginning
     values.subscribe(
-        [](long v){printf("[1] OnNext: %d\n", v);},
+        [](long v){printf("[1] OnNext: %ld\n", v);},
         [](){printf("[1] OnCompleted\n");});
-    
+
     // Another subscription from the beginning
     values.subscribe(
-        [](long v){printf("[2] OnNext: %d\n", v);},
+        [](long v){printf("[2] OnNext: %ld\n", v);},
         [](){printf("[2] OnCompleted\n");});
 
     // Start emitting
     values.connect();
-    
+
     // Wait before subscribing
     rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){
         values.subscribe(
-            [](long v){printf("[3] OnNext: %d\n", v);},
+            [](long v){printf("[3] OnNext: %ld\n", v);},
             [](){printf("[3] OnCompleted\n");});
     });
-    
+
     // Add blocking subscription to see results
     values.as_blocking().subscribe();
     printf("//! [publish subject sample]\n");
@@ -73,24 +73,24 @@ SCENARIO("publish behavior sample"){
 
     // Subscribe from the beginning
     values.subscribe(
-        [](long v){printf("[1] OnNext: %d\n", v);},
+        [](long v){printf("[1] OnNext: %ld\n", v);},
         [](){printf("[1] OnCompleted\n");});
-    
+
     // Another subscription from the beginning
     values.subscribe(
-        [](long v){printf("[2] OnNext: %d\n", v);},
+        [](long v){printf("[2] OnNext: %ld\n", v);},
         [](){printf("[2] OnCompleted\n");});
 
     // Start emitting
     values.connect();
-    
+
     // Wait before subscribing
     rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){
         values.subscribe(
-            [](long v){printf("[3] OnNext: %d\n", v);},
+            [](long v){printf("[3] OnNext: %ld\n", v);},
             [](){printf("[3] OnCompleted\n");});
     });
-    
+
     // Add blocking subscription to see results
     values.as_blocking().subscribe();
     printf("//! [publish behavior sample]\n");
diff --git a/Rx/v2/examples/doxygen/skip_until.cpp b/Rx/v2/examples/doxygen/skip_until.cpp
index 3e0202f..c539d8e 100644
--- a/Rx/v2/examples/doxygen/skip_until.cpp
+++ b/Rx/v2/examples/doxygen/skip_until.cpp
@@ -10,7 +10,7 @@ SCENARIO("skip_until sample"){
     auto values = source.skip_until(trigger);
     values.
         subscribe(
-            [](long v){printf("OnNext: %d\n", v);},
+            [](long v){printf("OnNext: %ld\n", v);},
             [](){printf("OnCompleted\n");});
     printf("//! [skip_until sample]\n");
 }
@@ -21,18 +21,18 @@ SCENARIO("threaded skip_until sample"){
     printf("//! [threaded skip_until sample]\n");
     printf("[thread %s] Start task\n", get_pid().c_str());
     auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){
-        printf("[thread %s] Source emits, value = %d\n", get_pid().c_str(), v);
+        printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v);
         return v;
     });
     auto trigger = rxcpp::observable<>::timer(std::chrono::milliseconds(25)).map([](long v){
-        printf("[thread %s] Trigger emits, value = %d\n", get_pid().c_str(), v);
+        printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v);
         return v;
     });
     auto values = source.skip_until(trigger, rxcpp::observe_on_new_thread());
     values.
         as_blocking().
         subscribe(
-            [](long v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
+            [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);},
             [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
     printf("[thread %s] Finish task\n", get_pid().c_str());
     printf("//! [threaded skip_until sample]\n");
diff --git a/Rx/v2/examples/doxygen/switch_on_next.cpp b/Rx/v2/examples/doxygen/switch_on_next.cpp
index b924f3e..72469c8 100644
--- a/Rx/v2/examples/doxygen/switch_on_next.cpp
+++ b/Rx/v2/examples/doxygen/switch_on_next.cpp
@@ -13,7 +13,7 @@ SCENARIO("switch_on_next sample"){
     auto values = base.switch_on_next().take(10);
     values.
         subscribe(
-            [](long v){printf("OnNext: %d\n", v);},
+            [](long v){printf("OnNext: %ld\n", v);},
             [](){printf("OnCompleted\n");});
     printf("//! [switch_on_next sample]\n");
 }
@@ -29,7 +29,7 @@ SCENARIO("threaded switch_on_next sample"){
     values.
         as_blocking().
         subscribe(
-            [](long v){printf("OnNext: %d\n", v);},
+            [](long v){printf("OnNext: %ld\n", v);},
             [](){printf("OnCompleted\n");});
     printf("//! [threaded switch_on_next sample]\n");
 }
diff --git a/Rx/v2/examples/doxygen/take_until.cpp b/Rx/v2/examples/doxygen/take_until.cpp
index 35e235a..5c98bc4 100644
--- a/Rx/v2/examples/doxygen/take_until.cpp
+++ b/Rx/v2/examples/doxygen/take_until.cpp
@@ -10,7 +10,7 @@ SCENARIO("take_until sample"){
     auto values = source.take_until(trigger);
     values.
         subscribe(
-            [](long v){printf("OnNext: %d\n", v);},
+            [](long v){printf("OnNext: %ld\n", v);},
             [](){printf("OnCompleted\n");});
     printf("//! [take_until sample]\n");
 }
@@ -21,7 +21,7 @@ SCENARIO("take_until time sample"){
     auto values = source.take_until(std::chrono::steady_clock::now() + std::chrono::milliseconds(25));
     values.
         subscribe(
-            [](long v){printf("OnNext: %d\n", v);},
+            [](long v){printf("OnNext: %ld\n", v);},
             [](){printf("OnCompleted\n");});
     printf("//! [take_until time sample]\n");
 }
@@ -32,18 +32,18 @@ SCENARIO("threaded take_until sample"){
     printf("//! [threaded take_until sample]\n");
     printf("[thread %s] Start task\n", get_pid().c_str());
     auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){
-        printf("[thread %s] Source emits, value = %d\n", get_pid().c_str(), v);
+        printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v);
         return v;
     });
     auto trigger = rxcpp::observable<>::timer(std::chrono::milliseconds(25)).map([](long v){
-        printf("[thread %s] Trigger emits, value = %d\n", get_pid().c_str(), v);
+        printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v);
         return v;
     });
     auto values = source.take_until(trigger, rxcpp::observe_on_new_thread());
     values.
         as_blocking().
         subscribe(
-            [](long v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
+            [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);},
             [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
     printf("[thread %s] Finish task\n", get_pid().c_str());
     printf("//! [threaded take_until sample]\n");
@@ -53,7 +53,7 @@ SCENARIO("threaded take_until time sample"){
     printf("//! [threaded take_until time sample]\n");
     printf("[thread %s] Start task\n", get_pid().c_str());
     auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){
-        printf("[thread %s] Source emits, value = %d\n", get_pid().c_str(), v);
+        printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v);
         return v;
     });
     auto scheduler = rxcpp::observe_on_new_thread();
@@ -61,7 +61,7 @@ SCENARIO("threaded take_until time sample"){
     values.
         as_blocking().
         subscribe(
-            [](long v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
+            [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);},
             [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
     printf("[thread %s] Finish task\n", get_pid().c_str());
     printf("//! [threaded take_until time sample]\n");
diff --git a/Rx/v2/examples/doxygen/window.cpp b/Rx/v2/examples/doxygen/window.cpp
index 0a0ba63..2f3e670 100644
--- a/Rx/v2/examples/doxygen/window.cpp
+++ b/Rx/v2/examples/doxygen/window.cpp
@@ -50,7 +50,7 @@ SCENARIO("window period+skip+coordination sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period+skip+coordination sample]\n");
@@ -70,7 +70,7 @@ SCENARIO("window period+skip sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period+skip sample]\n");
@@ -90,7 +90,7 @@ SCENARIO("window period+skip overlapping sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period+skip overlapping sample]\n");
@@ -109,7 +109,7 @@ SCENARIO("window period+skip empty sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period+skip empty sample]\n");
@@ -128,7 +128,7 @@ SCENARIO("window period+coordination sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period+coordination sample]\n");
@@ -146,7 +146,7 @@ SCENARIO("window period sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period sample]\n");
@@ -168,7 +168,7 @@ SCENARIO("window period+count+coordination sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period+count+coordination sample]\n");
@@ -189,7 +189,7 @@ SCENARIO("window period+count sample"){
                 int id = counter++;
                 printf("[window %d] Create window\n", id);
                 v.subscribe(
-                    [id](long v){printf("[window %d] OnNext: %d\n", id, v);},
+                    [id](long v){printf("[window %d] OnNext: %ld\n", id, v);},
                     [id](){printf("[window %d] OnCompleted\n", id);});
             });
     printf("//! [window period+count sample]\n");