aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/sharder.ml2
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/sharder.ml b/lib/sharder.ml
index 0edb707..4e6cc46 100644
--- a/lib/sharder.ml
+++ b/lib/sharder.ml
@@ -282,7 +282,7 @@ module Shard = struct
Pipe.write_if_open (snd shard.pipe) (Frame.create ~opcode:Frame.Opcode.Close ~final:true ())
>>= fun _ ->
Ivar.fill shard.hb_stopper ();
- Writer.close (snd shard._internal)
+ Writer.close ~force_close:(Deferred.never ()) (snd shard._internal)
let recreate shard =
shutdown_clean shard >>= fun () ->