Function makeReadTask

pkg/console/internal/events/tasks.go:37–66

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

}

func makeReadTask(
	conn *websocket.Conn, m eventsmux.Interface, rateLimit func() error, cancel func(error),
) func(context.Context) error {
	return func(ctx context.Context) (err error) {
		defer func() { cancel(err) }()
		defer func() {
			if closeErr := (websocket.CloseError{}); errors.As(err, &closeErr) {
				log.FromContext(ctx).WithFields(log.Fields(
					"code", closeErr.Code,
					"reason", closeErr.Reason,
				)).Debug("WebSocket closed")
				err = io.EOF
			}
		}()
		for {
			var request protocol.RequestWrapper
			if err := wsjson.Read(ctx, conn, &request); err != nil {
				return err
			}
			if err := rateLimit(); err != nil {
				return err
			}
			select {
			case <-ctx.Done():
				return ctx.Err()
			case m.Requests() <- request.Contents:
			}
		}
	}
}

func makeWriteTask(conn *websocket.Conn, m eventsmux.Interface, cancel func(error)) func(context.Context) error {
	return func(ctx context.Context) (err error) {