diff --git a/horizon.dhall b/horizon.dhall
index fa8668cde8043040e119976c66ede7320c039799..00255ad46282e1c86cd35f9e9f080a8ed3b690f2 100644
--- a/horizon.dhall
+++ b/horizon.dhall
@@ -763,6 +763,7 @@ let packages =
       , stm-chans = H.callHackage "stm-chans" "3.0.0.6"
       , streaming-commons = H.callHackage "streaming-commons" "0.2.2.4"
       , streaming = H.callHackage "streaming" "0.2.3.1"
+      , streamly = H.callHackage "streamly" "0.8.3"
       , store-core = H.callHackage "store-core" "0.4.4.4"
       , store = H.callHackage "store" "0.7.16"
       , strict = H.callHackage "strict" "0.4.0.1"
diff --git a/initial-packages.nix b/initial-packages.nix
index 86326d159e641d5d533ad82aa1e237e46e640eee..5d69828c02e8656c7013a8643255b6d089c09923 100644
--- a/initial-packages.nix
+++ b/initial-packages.nix
@@ -1249,6 +1249,8 @@ self: with pkgs.haskell.lib; {
 
   streaming-commons = self.callPackage (./pkgs/streaming-commons.nix) { };
 
+  streamly = self.callPackage (./pkgs/streamly.nix) { };
+
   strict = self.callPackage (./pkgs/strict.nix) { };
 
   string-conv = self.callPackage (./pkgs/string-conv.nix) { };
diff --git a/pkgs/streamly.nix b/pkgs/streamly.nix
new file mode 100644
index 0000000000000000000000000000000000000000..6bf5864f1c140ecc770f6172400340ce75f06b5f
--- /dev/null
+++ b/pkgs/streamly.nix
@@ -0,0 +1,60 @@
+{ mkDerivation
+, atomic-primops
+, base
+, containers
+, deepseq
+, directory
+, exceptions
+, filepath
+, fusion-plugin-types
+, ghc-prim
+, heaps
+, lib
+, lockfree-queue
+, monad-control
+, mtl
+, network
+, primitive
+, transformers
+, transformers-base
+, unicode-data
+}:
+mkDerivation {
+  pname = "streamly";
+  version = "0.8.3";
+  sha256 = "af8bc4fb86ba41f8970a9147e9ad290d17f44db123ea3db29bd04404fdcc5b76";
+  isLibrary = true;
+  isExecutable = false;
+  enableSeparateDataOutput = false;
+  libraryHaskellDepends = [
+    atomic-primops
+    base
+    containers
+    deepseq
+    directory
+    exceptions
+    filepath
+    fusion-plugin-types
+    ghc-prim
+    heaps
+    lockfree-queue
+    monad-control
+    mtl
+    network
+    primitive
+    transformers
+    transformers-base
+    unicode-data
+  ];
+  enableLibraryProfiling = true;
+  enableExecutableProfiling = true;
+  doHaddock = false;
+  jailbreak = true;
+  doCheck = false;
+  doBenchmark = false;
+  hyperlinkSource = false;
+  homepage = "https://streamly.composewell.com";
+  description = "Dataflow programming and declarative concurrency";
+  license = lib.licenses.bsd3;
+  broken = false;
+}