“Attitude is everything” is a small and interesting book by Jeff Keller. The language used is simple and easy to understand. The strategies are effective. The book is divided into 3 parts by the author himself. Part 1: Success Begins in the Mind — Focuses on the way of THINKING …

“Attitude is everything” is a small and interesting book by Jeff Keller. The language used is simple and easy to understand. The strategies are effective. The book is divided into 3 parts by the author himself. Part 1: Success Begins in the Mind — Focuses on the way of THINKING …

“Attitude is everything” is a small and interesting book by Jeff Keller. The language used is simple and easy to understand. The strategies are effective. The book is divided into 3 parts by the author himself. Part 1: Success Begins in the Mind — Focuses on the way of THINKING …

“Attitude is everything” is a small and interesting book by Jeff Keller. The language used is simple and easy to understand. The strategies are effective. The book starts with an introduction about the author and how he changed his life Since his early teenage years, Jeff was interested in becoming…

For the sake of getting straight to the point, we will assume followings, so that we can look directly into testing. We have a RestController with two get mappings. ‘/flux’ returns Flux<Integer> in default media type — application/json. ‘/fluxStream’ returns Flux<Long> in — application/stream+json OR application/x-ndjson. ‘/flux’ is finite and…

Let’s suppose there is a producer that produces integers 1 to 10. Now, a subscriber will subscribe and request for data. The publisher starts sending data through onNext() event. When the publisher has sent 3 onNext() events, another subscriber (subscriber-2) will subscribe and request for data. …

Earlier, we saw how to check/ verify errors in the stream. Flux<String> strFlux = Flux.just("These","Strings","will","create","flux") .concatWith(Flux.error(new RuntimeException("Exception Occured"))) .concatWith(Flux.just("After Error")); StepVerifier.create(strFlux) .expectNext("These","Strings","will","create","flux") .expectError(RuntimeException.class) .verify(); Now let’s see how to handle the error.

Let’s look at some of the operations that can be done on a Reactive Stream (Flux/ Mono) and play around with the stream. Filtering Reactive Stream We can filter a stream based on a predicate (condition) provided as an argument with the filter() method. If we wanted to filter a string stream and…

In this post, we will discuss different ways to create Flux/Mono. Flux From List (or any other Iterable data type): Flux<String> strFlux = Flux.fromIterable(strList); From Array: Flux<String> strFlux = Flux.fromArray(strArray); From Stream: Stream is an API included in JDK from Java 8. It can be used to process collection from iterables. Visit this page for more on Java 8 Streams: https://www.geeksforgeeks.org/stream-in-java/