Method Set

kayak/runtime.go:154–159

(cr *commitResult)

}

func (f *commitFuture) Set(cr *commitResult) {
	select {
	case f.ch <- cr:
	default:
	}
}

// NewRuntime creates new kayak Runtime.
func NewRuntime(cfg *kt.RuntimeConfig) (rt *Runtime, err error) {