diff --git a/process.go b/process.go
index 6a1fb552c..3f6edcd0d 100644
--- a/process.go
+++ b/process.go
@@ -88,3 +88,11 @@ func (p *process) Wait(ctx context.Context) (uint32, error) {
 		}
 	}
 }
+
+func (p *process) CloseStdin(ctx context.Context) error {
+	_, err := p.task.client.TaskService().CloseStdin(ctx, &execution.CloseStdinRequest{
+		ContainerID: p.task.containerID,
+		Pid:         p.pid,
+	})
+	return err
+}
diff --git a/task.go b/task.go
index b56f0db99..bee50db66 100644
--- a/task.go
+++ b/task.go
@@ -40,6 +40,7 @@ type Process interface {
 	Start(context.Context) error
 	Kill(context.Context, syscall.Signal) error
 	Wait(context.Context) (uint32, error)
+	CloseStdin(context.Context) error
 }
 
 var _ = (Task)(&task{})