Commitd259dcc

committed

AcivityWriter

1 parent4115a09 commitd259dccCopy full SHA for d259dcc

File tree

+22

-38

lines changed

+22

-38

lines changed

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -147,10 +147,11 @@ func runCommand(ctx context.Context, envName string, command string, args []stri`
`147`	`147`	`stdin:=process.Stdin()`
`148`	`148`	`deferstdin.Close()`
`149`	`149`
`150`		`-ap:=&activity.Pusher{Source:"ssh",EnvID:env.ID,Client:entClient}`
	`150`	`+ap:=&activity.Pusher{Source:sshActivityName,EnvID:env.ID,Client:entClient}`
`151`	`151`	`deferap.Start()()`
`152`	`152`
`153`		`-_,err:=activity.Copy(ap,stdin,os.Stdin)`
	`153`	`+wr:=activity.Writer(ap,stdin)`
	`154`	`+_,err:=io.Copy(wr,os.Stdin)`
`154`	`155`	`iferr!=nil {`
`155`	`156`	`cancel()`
`156`	`157`	`}`
`@@ -173,3 +174,5 @@ func runCommand(ctx context.Context, envName string, command string, args []stri`
`173`	`174`	`}`
`174`	`175`	`returnerr`
`175`	`176`	`}`
	`177`	`+`
	`178`	`+constsshActivityName="ssh"`

Lines changed: 0 additions & 36 deletions

This file was deleted.

Lines changed: 17 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,17 @@`
	`1`	`+package activity`
	`2`	`+`
	`3`	`+import"io"`
	`4`	`+`
	`5`	`+typeactivityWriterstruct {`
	`6`	`+p*Pusher`
	`7`	`+wr io.Writer`
	`8`	`+}`
	`9`	`+`
	`10`	`+func (w*activityWriter)Write(p []byte) (nint,errerror) {`
	`11`	`+w.p.Push()`
	`12`	`+returnw.wr.Write(p)`
	`13`	`+}`
	`14`	`+`
	`15`	`+funcWriter(p*Pusher,wr io.Writer) io.Writer {`
	`16`	`+return&activityWriter{p:p,wr:wr}`
	`17`	`+}`

Comments

(0)