Function resumableStateFromContext

resumable.go:172–184

(ctx context.Context)

}

func resumableStateFromContext(ctx context.Context) (*rivermiddleware.ResumableState, bool) {
	state := ctx.Value(rivermiddleware.ResumableContextKey{})
	if state == nil {
		return nil, false
	}

	typedState, ok := state.(*rivermiddleware.ResumableState)
	if !ok || typedState == nil {
		return nil, false
	}

	return typedState, true
}