diff --git a/horizon.dhall b/horizon.dhall
index 1dd7f94f62a6304fcbe04ae40f862fbf57bc2e87..7680e2ce97349f0f357c146e9f0a5c9855e6e7a8 100644
--- a/horizon.dhall
+++ b/horizon.dhall
@@ -1079,7 +1079,11 @@ let packages =
       , storable-tuple = H.callHackage "storable-tuple" "0.1"
       , store = H.callHackage "store" "0.7.16"
       , store-core = H.callHackage "store-core" "0.4.4.4"
-      , streaming = H.callHackage "streaming" "0.2.3.1"
+      , streaming =
+          H.callGit
+            "https://github.com/haskell-streaming/streaming"
+            "b6ec199103c078a07b3dcd197ab39020b2136426"
+            (None H.Subdir)
       , streaming-binary = H.callHackage "streaming-binary" "0.3.0.1"
       , streaming-bytestring = H.callHackage "streaming-bytestring" "0.2.4"
       , streaming-commons = H.callHackage "streaming-commons" "0.2.2.5"
diff --git a/pkgs/streaming.nix b/pkgs/streaming.nix
index 04bf2e7ecd495075c0ce33290008c606d08c4925..ea741ebb5d13bb45873c40a22b9b98f28b7244e1 100644
--- a/pkgs/streaming.nix
+++ b/pkgs/streaming.nix
@@ -1,30 +1,20 @@
-{ mkDerivation
-, QuickCheck
-, base
-, containers
-, ghc-prim
-, hspec
-, lib
-, mmorph
-, mtl
-, transformers
-, transformers-base
+{ mkDerivation, QuickCheck, base, containers, fetchgit, ghc-prim
+, hspec, lib, mmorph, mtl, transformers, transformers-base
 }:
 mkDerivation {
   pname = "streaming";
   version = "0.2.3.1";
-  sha256 = "fc5efae393750b9729ce5c5e979edcd3b9a5bf41ab927636174b01f999ffea88";
+  src = fetchgit {
+    url = "https://github.com/haskell-streaming/streaming";
+    sha256 = "193qwgzpd6ryzi3sl3x6bc5kk47whqhw0mfr0jqfdwrspj50ccdd";
+    rev = "b6ec199103c078a07b3dcd197ab39020b2136426";
+    fetchSubmodules = true;
+  };
   isLibrary = true;
   isExecutable = false;
   enableSeparateDataOutput = false;
   libraryHaskellDepends = [
-    base
-    containers
-    ghc-prim
-    mmorph
-    mtl
-    transformers
-    transformers-base
+    base containers ghc-prim mmorph mtl transformers transformers-base
   ];
   testHaskellDepends = [ base hspec QuickCheck ];
   enableLibraryProfiling = true;
@@ -38,4 +28,4 @@ mkDerivation {
   description = "an elementary streaming prelude and general stream type";
   license = lib.licenses.bsd3;
   broken = false;
-}
+}
\ No newline at end of file