From 34fdd4fd90e84595cf29cd9db494bdfa073f17c7 Mon Sep 17 00:00:00 2001
From: shedaniel <daniel@shedaniel.me>
Date: Fri, 22 Oct 2021 14:43:36 +0800
Subject: Fix #644

---
 .../impl/common/compat/FabricFluidAPISupportPlugin.java  | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

(limited to 'fabric/src/main/java')

diff --git a/fabric/src/main/java/me/shedaniel/rei/impl/common/compat/FabricFluidAPISupportPlugin.java b/fabric/src/main/java/me/shedaniel/rei/impl/common/compat/FabricFluidAPISupportPlugin.java
index 74d74698a..3e64ecf8b 100644
--- a/fabric/src/main/java/me/shedaniel/rei/impl/common/compat/FabricFluidAPISupportPlugin.java
+++ b/fabric/src/main/java/me/shedaniel/rei/impl/common/compat/FabricFluidAPISupportPlugin.java
@@ -48,15 +48,17 @@ public class FabricFluidAPISupportPlugin implements REIServerPlugin {
         support.register(entry -> {
             ItemStack stack = entry.getValue().copy();
             Storage<FluidVariant> storage = FluidStorage.ITEM.find(stack, ContainerItemContext.withInitial(stack));
-            List<EntryStack<FluidStack>> result;
-            try (Transaction transaction = Transaction.openOuter()) {
-                result = StreamSupport.stream(storage.iterable(transaction).spliterator(), false)
+            if (storage != null) {
+                List<EntryStack<FluidStack>> result;
+                try (Transaction transaction = Transaction.openOuter()) {
+                    result = StreamSupport.stream(storage.iterable(transaction).spliterator(), false)
                         .filter(view -> !view.isResourceBlank() && !view.getResource().isBlank())
                         .map(view -> EntryStacks.of(FluidStack.create(view.getResource().getFluid(), Fraction.of(view.getAmount(), FluidConstants.BUCKET), view.getResource().getNbt())))
-                        .collect(Collectors.toList());
-            }
-            if (!result.isEmpty()) {
-                return CompoundEventResult.interruptTrue(result.stream());
+                            .collect(Collectors.toList());
+                }
+                if (!result.isEmpty()) {
+                    return CompoundEventResult.interruptTrue(result.stream());
+                }
             }
             return CompoundEventResult.pass();
         });
-- 
cgit