diff options
| -rw-r--r-- | tvix/castore/src/directoryservice/grpc.rs | 13 |
1 files changed, 3 insertions, 10 deletions
diff --git a/tvix/castore/src/directoryservice/grpc.rs b/tvix/castore/src/directoryservice/grpc.rs index ad06cb17b668..fbb9cce64e88 100644 --- a/tvix/castore/src/directoryservice/grpc.rs +++ b/tvix/castore/src/directoryservice/grpc.rs @@ -201,7 +201,9 @@ impl DirectoryService for GRPCDirectoryService { Ok(s) }); - Box::new(GRPCPutter::new(tx, task)) + Box::new(GRPCPutter { + rq: Some((task, tx)), + }) } } @@ -219,15 +221,6 @@ pub struct GRPCPutter { } impl GRPCPutter { - pub fn new( - directory_sender: UnboundedSender<proto::Directory>, - task: JoinHandle<Result<proto::PutDirectoryResponse, Status>>, - ) -> Self { - Self { - rq: Some((task, directory_sender)), - } - } - // allows checking if the tx part of the channel is closed. // only used in the test case. #[cfg(test)] |