From 5363af6b7f41cc623f8697acdfb2e43d77e40a15 Mon Sep 17 00:00:00 2001
From: Anu Thomas Chandy <anuamd@hotmail.com>
Date: Sun, 5 Jan 2020 16:16:31 -0800
Subject: [PATCH] Explicitly specify type in code-snippet

---
 .../rest/PagedFluxJavaDocCodeSnippets.java    | 46 ++++++++++---------
 .../PagedFluxCoreJavaDocCodeSnippets.java     |  2 +-
 2 files changed, 25 insertions(+), 23 deletions(-)

diff --git a/sdk/core/azure-core/src/samples/java/com/azure/core/http/rest/PagedFluxJavaDocCodeSnippets.java b/sdk/core/azure-core/src/samples/java/com/azure/core/http/rest/PagedFluxJavaDocCodeSnippets.java
index 84e90eac9299..4dbc8f5762a2 100644
--- a/sdk/core/azure-core/src/samples/java/com/azure/core/http/rest/PagedFluxJavaDocCodeSnippets.java
+++ b/sdk/core/azure-core/src/samples/java/com/azure/core/http/rest/PagedFluxJavaDocCodeSnippets.java
@@ -164,32 +164,34 @@ public void pagedFluxFromPagedFlux() {
                 intResponse.getContinuationToken(),
                 null);
 
-        final Supplier<PageRetriever<String, PagedResponse<String>>> provider = new Supplier<>() {
-            @Override
-            public PageRetriever<String, PagedResponse<String>> get() {
-                return (continuationToken, pageSize) -> {
-                    Flux<PagedResponse<Integer>> flux = (continuationToken == null)
-                        ? intPagedFlux.byPage()
-                        : intPagedFlux.byPage(continuationToken);
-                    return flux.map(responseMapper);
-                };
-            }
-        };
+        final Supplier<PageRetriever<String, PagedResponse<String>>> provider
+            = new Supplier<PageRetriever<String, PagedResponse<String>>>() {
+                @Override
+                public PageRetriever<String, PagedResponse<String>> get() {
+                    return (continuationToken, pageSize) -> {
+                        Flux<PagedResponse<Integer>> flux = (continuationToken == null)
+                            ? intPagedFlux.byPage()
+                            : intPagedFlux.byPage(continuationToken);
+                        return flux.map(responseMapper);
+                    };
+                }
+            };
         PagedFlux<String> strPagedFlux = PagedFlux.create(provider);
 
         // Create a PagedFlux from a PagedFlux with all exceptions mapped to a specific exception.
         final PagedFlux<Integer> pagedFlux = createAnInstance();
-        final Supplier<PageRetriever<String, PagedResponse<Integer>>> eprovider = new Supplier<>() {
-            @Override
-            public PageRetriever<String, PagedResponse<Integer>> get() {
-                return (continuationToken, pageSize) -> {
-                    Flux<PagedResponse<Integer>> flux = (continuationToken == null)
-                        ? pagedFlux.byPage()
-                        : pagedFlux.byPage(continuationToken);
-                    return flux.onErrorMap(t -> new PaginationException(t));
-                };
-            }
-        };
+        final Supplier<PageRetriever<String, PagedResponse<Integer>>> eprovider
+            = new Supplier<PageRetriever<String, PagedResponse<Integer>>>() {
+                @Override
+                public PageRetriever<String, PagedResponse<Integer>> get() {
+                    return (continuationToken, pageSize) -> {
+                        Flux<PagedResponse<Integer>> flux = (continuationToken == null)
+                            ? pagedFlux.byPage()
+                            : pagedFlux.byPage(continuationToken);
+                        return flux.onErrorMap(t -> new PaginationException(t));
+                    };
+                }
+            };
         final PagedFlux<Integer> exceptionMappedPagedFlux = PagedFlux.create(eprovider);
         // END: com.azure.core.http.rest.pagedflux.create.decoration
     }
diff --git a/sdk/core/azure-core/src/samples/java/com/azure/core/util/paging/PagedFluxCoreJavaDocCodeSnippets.java b/sdk/core/azure-core/src/samples/java/com/azure/core/util/paging/PagedFluxCoreJavaDocCodeSnippets.java
index 8702466138cd..c1d2182a3fff 100644
--- a/sdk/core/azure-core/src/samples/java/com/azure/core/util/paging/PagedFluxCoreJavaDocCodeSnippets.java
+++ b/sdk/core/azure-core/src/samples/java/com/azure/core/util/paging/PagedFluxCoreJavaDocCodeSnippets.java
@@ -68,7 +68,7 @@ Flux<FilePage> getFilePages(FileContinuationToken token) {
         FileShareServiceClient client = null; // Initialize client
 
         Supplier<PageRetriever<FileContinuationToken, FilePage>> pageRetrieverProvider
-            = new Supplier<>() {
+            = new Supplier<PageRetriever<FileContinuationToken, FilePage>>() {
                 @Override
                 public PageRetriever<FileContinuationToken, FilePage> get() {
                     return (continuationToken, pageSize) -> client.getFilePages(continuationToken);