@Test
public void cleanupErrorCloseFuture() {

	//use an extra handler
	EmbeddedChannel channel = new EmbeddedChannel(new ChannelHandlerAdapter() {});
	Mono<Void> m = MonoSendMany.objectSource(Mono.error(new Exception("boo")), channel, b -> false);
	List<WeakReference<Subscription>> _w = new ArrayList<>(1);
	StepVerifier.create(m)
	            .consumeSubscriptionWith(s -> _w.add(new WeakReference<>(s)))
	            .then(channel::runPendingTasks)
	            .verifyErrorMessage("boo");
	System.gc();
	wait(_w.get(0));
}