How to get String from Mono in reactive java

by

Getting a String from a Mono<String> without a blocking call isn’t easy, it’s impossible. By definition. If the String isn’t available yet (which Mono<String> allows), you can’t get it except by waiting until it comes in and that’s exactly what blocking is.

Instead of “getting a String” you subscribe to the Mono and the Subscriber you pass will get the String when it becomes available (maybe immediately). E.g.

myMono.subscribe(
  value -> System.out.println(value), 
  error -> error.printStackTrace(), 
  () -> System.out.println("completed without a value")
)

will print the value or error produced by myMono (type of value is String, type of error is Throwable). At https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html you can see other variants of subscribe too.

More Related Contents:

  1. Why doesn’t java.util.Collection implement the new Stream interface?
  2. Java lambda returning a lambda
  3. Does Java SE 8 have Pairs or Tuples?
  4. Java 8 Supplier with arguments in the constructor
  5. Convert String array to Map using Java 8 Lambda expressions
  6. Purpose of third argument to ‘reduce’ function in Java 8 functional programming
  7. Java Reconstruct data structure using lambda expression
  8. What are functional interfaces used for in Java 8?
  9. Why filter() after flatMap() is “not completely” lazy in Java streams?
  10. How to serialize a lambda?
  11. What is the equivalent lambda expression for System.out::println
  12. Copy a stream to avoid “stream has already been operated upon or closed”
  13. Does a lambda expression create an object on the heap every time it’s executed?
  14. Precise definition of “functional interface” in Java 8
  15. How to get the MethodInfo of a Java 8 method reference?
  16. Java 8: Difference between method reference Bound Receiver and UnBound Receiver
  17. Group by and sum objects like in SQL with Java lambdas?
  18. Lambda expression vs method reference
  19. Java 8 Lambda Expressions – what about multiple methods in nested class
  20. Lambda this reference in java
  21. java.lang.ClassCastException using lambda expressions in spark job on remote server
  22. Java 8: Where is TriFunction (and kin) in java.util.function? Or what is the alternative?
  23. How do I use the new computeIfAbsent function?
  24. How to get a range of items from stream using Java 8 lambda?
  25. block()/blockFirst()/blockLast() are blocking error when calling bodyToMono AFTER exchange()
  26. Local variable log defined in an enclosing scope must be final or effectively final
  27. Java 8: Mandatory checked exceptions handling in lambda expressions. Why mandatory, not optional?
  28. Java 8 Filter Array Using Lambda
  29. Lambdas in the classical Operation enum example
  30. Are Java 8 lambdas compiled as inner classes, methods or something else? [duplicate]

Leave a Comment