diff --git a/zfs/zfs.go b/zfs/zfs.go
index e518829..f77110d 100644
--- a/zfs/zfs.go
+++ b/zfs/zfs.go
@@ -814,6 +814,7 @@ func ZFSRecv(ctx context.Context, fs string, streamCopier StreamCopier, opts Rec
 	copierErrChan := make(chan StreamCopierError)
 	go func() {
 		copierErrChan <- streamCopier.WriteStreamTo(stdinWriter)
+		stdinWriter.Close()
 	}()
 	waitErrChan := make(chan *ZFSError)
 	go func() {