example3

package

v0.0.0-...-69e4c68 Latest Latest Go to latest Published: Oct 21, 2020 License: Apache-2.0 Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Complete func(p Promise, err error)

Complete callback for Then

type GenericPromise struct {
	// contains filtered or unexported fields
}

GenericPromise struct for adding to other objects

func (p GenericPromise) Repl() chan Promise

Repl channel

func (p *GenericPromise) Super()

Super constructs yourself. Must be called by child implementations

func (p *GenericPromise) Then(ctx context.Context, call Complete)

Then call the function on itself

type MyPromise struct {
	GenericPromise
	// contains filtered or unexported fields
}

MyPromise of local data

type Open func() Promise

Open creates the promise

func MyPromiseConstructor(i int) Open

MyPromiseConstructor can construct promises of type MyPromise

type Processor func(pr Promise)

Processor callback for the promise to be acted on

type Promise interface {
	Then(ctx context.Context, call Complete)
	Repl() chan Promise
}

Promise is something that does async work

type Promiser chan Promise

Promiser takes requests and returns promises

func (p Promiser) Request(open Open) Promise

Request something

func (p Promiser) Run(ctx context.Context, work Processor)

Run the processor for the Promiser