Attempt.kt

    fun get(@PathVariable identifier: String): MutableList<in Quote> {
        return defer { fromIterable( quoteRepository.getAll(identifier)) }
                .subscribeOn(Computations.concurrent())
                .stream()
                .collect(
                        Collectors.toList());
    }

question.md

Version is io.projectreactor:reactor-core:2.5.0.M3 I'm getting when try to run the code on Attempt.kt:

java.lang.IllegalStateException: Queue empty?!
	at reactor.core.publisher.BlockingIterable$SubscriberIterator.next(BlockingIterable.java:203) ~[reactor-core-2.5.0.M3.jar:na]
	at java.util.Iterator.forEachRemaining(Iterator.java:116) ~[na:1.8.0_65]
	at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) ~[na:1.8.0_65]
	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[na:1.8.0_65]
	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[na:1.8.0_65]
	at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[na:1.8.0_65]
	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[na:1.8.0_65]
	at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) ~[na:1.8.0_65]
	at com.invasionofsmallcubes.reactiveflow.ReactiveEndpoint.get(ReactiveApplication.kt:37)