forgot handle func and change registerjob channel

server/neptune/temporalworker/job/noop_stream_handler.go

@@ -2,12 +2,27 @@ package job
 
 import (
 	"context"
+	"sync"
 )
 
-type NoopStreamHandler struct{}
+type NoopStreamHandler struct {
+	wg sync.WaitGroup
+}
 
 func (n *NoopStreamHandler) RegisterJob(id string) chan string {
-	return make(chan string)
+	jobOutput := make(chan string)
+	n.wg.Add(1)
+	go func() {
+		defer n.wg.Done()
+		for line := range jobOutput {
+			n.handle(&OutputLine{
+				JobID: id,
+				Line:  line,
+			})
+		}
+	}()
+
+	return jobOutput
 }
 
 func (n *NoopStreamHandler) CloseJob(ctx context.Context, jobID string) error {
@@ -17,3 +32,6 @@ func (n *NoopStreamHandler) CloseJob(ctx context.Context, jobID string) error {
 func (n *NoopStreamHandler) CleanUp(ctx context.Context) error {
 	return nil
 }
+
+func (s *NoopStreamHandler) handle(_ *OutputLine) {
+}