Function makeWriteTask

pkg/console/internal/events/tasks.go:68–82

(conn *websocket.Conn, m eventsmux.Interface, cancel func(error))

}

func makeWriteTask(conn *websocket.Conn, m eventsmux.Interface, cancel func(error)) func(context.Context) error {
	return func(ctx context.Context) (err error) {
		defer func() { cancel(err) }()
		for {
			select {
			case <-ctx.Done():
				return ctx.Err()
			case response := <-m.Responses():
				if err := wsjson.Write(ctx, conn, response); err != nil {
					return err
				}
			}
		}
	}
}

func makePingTask(conn *websocket.Conn, cancel func(error), period time.Duration) func(context.Context) error {
	return func(ctx context.Context) (err error) {