Get stream from Fresco image pipeline.

ImagePipelineStreamGetter.java

private abstract class ImagePipelineStreamGetter {
    private String imageUrl;

    public ImagePipelineStreamGetter(String imageUrl) {
        this.imageUrl = imageUrl;
    }

    public abstract void onSuccess(InputStream stream);
    public abstract void onError(Throwable t);

    public void get() {
        ImageRequest request = ImageRequestBuilder
                .newBuilderWithSource(Uri.parse(imageUrl))
                .build();
        ImagePipeline imagePipeline = Fresco.getImagePipeline();
        DataSource<CloseableReference<PooledByteBuffer>>
                dataSource = imagePipeline.fetchEncodedImage(request, getContext());
        dataSource.subscribe(new BaseDataSubscriber<CloseableReference<PooledByteBuffer>>() {
            @Override
            protected void onNewResultImpl(DataSource<CloseableReference<PooledByteBuffer>> dataSource) {
                if (!dataSource.isFinished()) {
                    return;
                }
                CloseableReference<PooledByteBuffer> ref = dataSource.getResult();
                if (ref != null) {
                    try {
                        PooledByteBuffer result = ref.get();
                        InputStream stream = new PooledByteBufferInputStream(result);
                        onSuccess(stream);
                    } finally {
                        CloseableReference.closeSafely(ref);
                    }
                }
            }

            @Override
            protected void onFailureImpl(DataSource<CloseableReference<PooledByteBuffer>> dataSource) {
                onError(dataSource.getFailureCause());
            }
        }, UiThreadImmediateExecutorService.getInstance());
    }
}