Jeroen Rosenberg jeroenr

Dev of the Ops. Founder of Amsterdam.scala. Passionate about Agile, Continuous Delivery. Proud father of four.

jeroenr / pitfall_9_fix.java

Created November 28, 2019 13:49

	interface Service {
	Flux<String> findAll();
	Mono<String> lookup(String s);
	}
	class Foo {
	private final Service service;

	Stream<String> problem() {
	return service.findAll().toStream();
	}

jeroenr / pitfall_9.java

Created November 28, 2019 13:35

	interface Service {
	Flux<String> findAll();
	}
	class Foo {
	private final Service service;

	Iterable<String> problem() {
	return service.findAll().toIterable();
	}
	}

jeroenr / pitfall_8_fix2.java

Created November 28, 2019 13:31

	interface Service {
	Flux<String> findAll();
	Mono<Void> operation(String s);
	}
	class Foo {
	private final Service service;

	Flux<Void> problem() {
	return service.findAll()
	.concatMap(service::operation);

jeroenr / pitfall_8_fix1.java

Created November 28, 2019 13:28

	interface Service {
	Flux<String> findAll();
	Mono<Void> operation(String s);
	}
	class Foo {
	private final Service service;

	Flux<Void> problem() {
	return service.findAll()
	.flatMap(service::operation, 4); // parallelism=4

jeroenr / pitfall_8.java

Created November 28, 2019 13:17

	interface Service {
	Flux<String> findAll();
	Mono<Void> operation(String s);
	}
	class Foo {
	private final Service service;

	Flux<Void> problem() {
	return service.findAll()
	.flatMap(service::operation);

jeroenr / pitfall_6.java

Created November 28, 2019 13:06

	abstract class UploadService {
	protected Mono<Void> doUpload(InputStream in);
	Mono<Void> upload(InputStream in) {
	doUpload(in).doFinally(x -> in.close());
	}
	}
	class Foo {
	private final UploadService service;

	Mono<Void> problem(byte[] data) {

jeroenr / pitfall_6.java

Last active November 28, 2019 12:52

	interface Service {
	Flux<Integer> findAll();
	}
	class Foo {
	private final Service service;

	Flux<Integer> problem() {
	AtomicInteger count = new AtomicInteger();
	return service.findAll()
	.doOnNext(count::addAndGet)

jeroenr / pitfall_5_fix.java

Created November 28, 2019 10:44

	interface Service {
	Mono<String> create(String s);
	Mono<Void> update(String s);
	}
	class Foo {
	private final Service service;

	Mono<Integer> problem() {
	return service.create("foo").flatMap(foo ->
	service.update(foo).thenReturn(foo.length())

jeroenr / pitfall_5.java

Created November 28, 2019 10:36

	interface Service {
	Mono<String> create(String s);
	Mono<Void> update(String s);
	}
	class Foo {
	private final Service service;

	Mono<Integer> problem() {
	return service.create("foo").map(foo -> {
	service.update(foo).subscribe();

jeroenr / pitfall_4_fix.java

Last active November 28, 2019 10:31

	interface Service {
	Mono<Void> update(String s);
	}
	class Foo {
	private final Service service;

	void problem() {
	service.update("foo").onErrorResume(e -> {
	e.printStackTrace();
	return Mono.empty();