diff --git a/firebase-inappmessaging/src/main/java/com/google/firebase/inappmessaging/internal/InAppMessageStreamManager.java b/firebase-inappmessaging/src/main/java/com/google/firebase/inappmessaging/internal/InAppMessageStreamManager.java
index 8c92cd005ad..d85ddc39c09 100644
--- a/firebase-inappmessaging/src/main/java/com/google/firebase/inappmessaging/internal/InAppMessageStreamManager.java
+++ b/firebase-inappmessaging/src/main/java/com/google/firebase/inappmessaging/internal/InAppMessageStreamManager.java
@@ -254,7 +254,7 @@ public Flowable<TriggeredInAppMessage> createFirebaseInAppMessageStream() {
                     }
 
                     // blocking get occurs on the IO thread because that's what we observeOn above
-                    return Maybe.fromCallable(getIID::blockingGet)
+                    return getIID
                         .filter(InAppMessageStreamManager::validIID)
                         .map(iid -> apiClient.getFiams(iid, campaignImpressionList))
                         .switchIfEmpty(Maybe.just(cacheExpiringResponse()))