@Test
public void cleanupFuseableErrorCloseFuture() {

	//use an extra handler
	EmbeddedChannel channel = new EmbeddedChannel(new ChannelHandlerAdapter() {});
	Mono<Void> m = MonoSendMany.objectSource(Flux.fromArray(new String[]{"test", "test2"}).concatWith(Mono.error(new Exception("boo"))).limitRate(10), channel, b -> false);
	List<WeakReference<Subscription>> _w = new ArrayList<>(1);
	StepVerifier.create(m)
	            .consumeSubscriptionWith(s -> _w.add(new WeakReference<>(s)))
	            .then(() -> {
		            channel.runPendingTasks();
		            assertThat(channel.<String>readOutbound()).isEqualToIgnoringCase("test");
		            assertThat(channel.<String>readOutbound()).isEqualToIgnoringCase("test2");
	            })
	            .verifyErrorMessage("boo");
	System.gc();
	wait(_w.get(0));
}