diff --git a/packages/ipfs-core-utils/src/files/normalise-content.js b/packages/ipfs-core-utils/src/files/normalise-content.js
index 05df86fea9..4d3e4fa9d6 100644
--- a/packages/ipfs-core-utils/src/files/normalise-content.js
+++ b/packages/ipfs-core-utils/src/files/normalise-content.js
@@ -14,7 +14,14 @@ import {
 /**
  * @param {import('./normalise').ToContent} input
  */
-export async function * normaliseContent (input) {
+export async function normaliseContent (input) {
+  return toAsyncGenerator(input)
+}
+
+/**
+ * @param {import('./normalise').ToContent} input
+ */
+async function * toAsyncGenerator (input) {
   // Bytes | String
   if (isBytes(input)) {
     yield toBytes(input)
diff --git a/packages/ipfs-core-utils/src/files/normalise.js b/packages/ipfs-core-utils/src/files/normalise.js
index df17c037ab..19b888943d 100644
--- a/packages/ipfs-core-utils/src/files/normalise.js
+++ b/packages/ipfs-core-utils/src/files/normalise.js
@@ -22,7 +22,7 @@ import {
 
 /**
  * @param {ImportCandidate | ImportCandidateStream} input
- * @param {(content:ToContent) => AsyncIterable<Uint8Array>} normaliseContent
+ * @param {(content:ToContent) => Promise<AsyncIterable<Uint8Array>>} normaliseContent
  */
 // eslint-disable-next-line complexity
 export async function * normalise (input, normaliseContent) {
@@ -72,6 +72,13 @@ export async function * normalise (input, normaliseContent) {
       return
     }
 
+    // fs.ReadStream<Bytes>
+    if (value._readableState) {
+      // @ts-ignore Node readable streams have a `.path` property so we need to pass it as the content
+      yield * map(peekable, (/** @type {ImportCandidate} */ value) => toFileObject({ content: value }, normaliseContent))
+      return
+    }
+
     // (Async)Iterable<Blob>
     // (Async)Iterable<String>
     // (Async)Iterable<{ path, content }>
@@ -103,7 +110,7 @@ export async function * normalise (input, normaliseContent) {
 
 /**
  * @param {ImportCandidate} input
- * @param {(content:ToContent) => AsyncIterable<Uint8Array>} normaliseContent
+ * @param {(content:ToContent) => Promise<AsyncIterable<Uint8Array>>} normaliseContent
  */
 async function toFileObject (input, normaliseContent) {
   // @ts-ignore - Those properties don't exist on most input types
@@ -117,7 +124,6 @@ async function toFileObject (input, normaliseContent) {
   }
 
   if (content) {
-  // @ts-ignore TODO vmx 2021-03-30 enable again
     file.content = await normaliseContent(content)
   } else if (!path) { // Not already a file object with path or content prop
     // @ts-ignore - input still can be different ToContent
diff --git a/packages/ipfs-core-utils/test/files/normalise-input.spec.js b/packages/ipfs-core-utils/test/files/normalise-input.spec.js
index 967ad00724..7f1c2d8706 100644
--- a/packages/ipfs-core-utils/test/files/normalise-input.spec.js
+++ b/packages/ipfs-core-utils/test/files/normalise-input.spec.js
@@ -6,6 +6,8 @@ import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string'
 import all from 'it-all'
 import { File } from '@web-std/file'
 import { normaliseInput } from '../../src/files/normalise-input.js'
+import { isNode } from 'ipfs-utils/src/env.js'
+import resolve from 'aegir/utils/resolve.js'
 
 const { Blob, ReadableStream } = globalThis
 
@@ -208,4 +210,31 @@ describe('normalise-input', function () {
   describe('TypedArray', () => {
     testInputType(TYPEDARRAY, 'TypedArray', true)
   })
+
+  if (isNode) {
+    /** @type {import('fs')} */
+    let fs
+
+    before(async () => {
+      fs = await import('fs')
+    })
+
+    describe('Node fs.ReadStream', () => {
+      const NODEFSREADSTREAM = () => {
+        const path = resolve('test/fixtures/file.txt', 'ipfs-core-utils')
+
+        return fs.createReadStream(path)
+      }
+
+      testInputType(NODEFSREADSTREAM, 'Node fs.ReadStream', false)
+
+      it('Iterable<Node fs.ReadStream>', async function () {
+        await testContent(iterableOf(NODEFSREADSTREAM()))
+      })
+
+      it('AsyncIterable<Node fs.ReadStream>', async function () {
+        await testContent(asyncIterableOf(NODEFSREADSTREAM()))
+      })
+    })
+  }
 })
diff --git a/packages/ipfs-core-utils/test/fixtures/file.txt b/packages/ipfs-core-utils/test/fixtures/file.txt
new file mode 100644
index 0000000000..95d09f2b10
--- /dev/null
+++ b/packages/ipfs-core-utils/test/fixtures/file.txt
@@ -0,0 +1 @@
+hello world
\ No newline at end of file
diff --git a/packages/ipfs-grpc-client/src/core-api/files/write.js b/packages/ipfs-grpc-client/src/core-api/files/write.js
index 74c851c19a..f463a78fd1 100644
--- a/packages/ipfs-grpc-client/src/core-api/files/write.js
+++ b/packages/ipfs-grpc-client/src/core-api/files/write.js
@@ -12,7 +12,7 @@ import {
  * @param {*} content
  */
 async function * stream (path, content) {
-  for await (const buf of normaliseContent(content)) {
+  for await (const buf of await normaliseContent(content)) {
     yield { path, content: buf }
   }
 }