reactor

type Callback func(context.Context, interface{}, error)

type Handler interface {
	Handle(ctx context.Context, req interface{}) (interface{}, error)
}

type HandlerFunc func(context.Context, interface{}) (interface{}, error)

type Reactor interface {
	// Send the reques to the reactor as an asynchronous call.
	Send(ctx context.Context, req interface{}, cb Callback) error
	// Do the request as a synchronous call.
	Do(ctx context.Context, req interface{}) (interface{}, error)
	// Register a message type handler
	RegisterHandler(msg interface{}, fn Handler)
}