martinandersson

package com.hello.controllerthread;

import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Get;
import io.reactivex.Single;

import java.util.Map;

@Controller("/thread")
public class ThreadEndpoint

martinandersson

package com.hello;

import io.reactivex.Observable;
import io.reactivex.disposables.Disposable;
import io.reactivex.observables.ConnectableObservable;

/**
 * Lesson learned: It is not the Observable that is disposed, it is the Observer
 * that may get disposed. Rx's API and documentation continuously describe
 * the Observable as the one being disposed, but this is wrong.

martinandersson

class DefaultFacade implements Facade
{
    @Inject
    OrderService service;
    
    @Override
    public void buttonClicked() {
        Instant dispatch = Instant.now().plus(2, ChronoUnit.HOURS);
        Order order = service.createOrder(dispatch);
        // ..

martinandersson

apply plugin: 'java'
apply plugin: 'java-library-distribution'

repositories {
    mavenCentral()
}

dependencies {
    compile 'org.apache.commons:commons-lang3:3.3.2'
}