使用Reactor将阻塞调用变为异步非阻塞

public String get(String url) throws IOException {
    HttpURLConnection connection = (HttpsURLConnection) new URL(url).openConnection();
    connection.setRequestMethod("GET");
    connection.setDoOutput(true);
    try(InputStream inputStream = connection.getInputStream()) {
        return new String(inputStream.readAllBytes(), StandardCharsets.UTF_8);
    }
}

package com.gkatzioura.blocking;
 
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
 
public class BlockingAsyncService {
 
    private final BlockingService blockingService;
 
    public BlockingAsyncService(BlockingService blockingService) {
        this.blockingService = blockingService;
    }
 
    private Mono<String> get(String url) {
        return Mono.fromCallable(() -> blockingService.get(url))
                .subscribeOn(Schedulers.boundedElastic());
    }
 
}

package com.gkatzioura.blocking;
 
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
 
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
 
class BlockingAsyncServiceTest {
 
    private BlockingAsyncService blockingAsyncService;
 
    @BeforeEach
    void setUp() {
        blockingAsyncService = new BlockingAsyncService(new BlockingService());
    }
 
    @Test
    void name() {
        StepVerifier.create(
                            Mono.just("https://www.google.com/")
                                .map(s -> blockingAsyncService.get(s))
                                .flatMap(s -> s)
                    )
                .consumeNextWith(s -> s.startsWith("<!doctype"))
                .verifyComplete();
    }
}