ribbon: Issues with blocking observable

Hi,

Having issues getting the blocking requests working. In order to support backwards compatibility in our clients we support returning both Observable<T> and T. To get the Observable we do:

    Observable<ByteBuf> observable = template.requestBuilder().build().observe();
    Observable<T> response = observable.map(new Func1<ByteBuf, T>() {
                @Override
                public T call(ByteBuf byteBuf) {
                    byteBuf.retain();
                     try {
                        InputStream stream = new ByteBufInputStream(byteBuf);
                        return streamToObject(stream, tClass);
                    } finally {
                        byteBuf.release();
                    }
              }});
    T item = response.toBlocking().last();

That works well for MOST of the times. However, sometimes we get: java.util.NoSuchElementException: Sequence contains no elements.

Anyone have any idea?