Vert.x 3.5.0 RxJava2 PumpTest

PumpTest.java

import static org.junit.Assert.assertEquals;

import java.io.File;
import java.io.IOException;

import org.apache.commons.io.FileUtils;
import org.junit.Test;

import io.reactivex.Observable;
import io.vertx.core.file.OpenOptions;
import io.vertx.reactivex.core.Vertx;
import io.vertx.reactivex.core.buffer.Buffer;
import io.vertx.reactivex.core.file.AsyncFile;
import io.vertx.reactivex.core.streams.Pump;

public class PumpTest {

	@Test
	public void testPump() throws IOException {
		Vertx vertx = Vertx.vertx();
		File file = new File("target/test");
		file.delete();

		Observable<Buffer> rs = Observable.just(Buffer.buffer("test123"));
		vertx.fileSystem().rxOpen(file.getAbsolutePath(), new OpenOptions()).map(f -> {
			Pump pump = Pump.pump(rs, f);
			pump.start();
			return f;
		}).map(AsyncFile::flush).toCompletable().blockingAwait();
		assertEquals("test123", FileUtils.readFileToString(file));
	}
}