runtime

type ClientRequestResponseHandler func(context.Context, []byte) ([]byte, error)

type ClientRequestResponseHandlerAsync func(context.Context, []byte) *mo.Future[[]byte]

type RequestWrapper struct {
	Selector   uint64
	MethodName string
	Payload    []byte
}

type Server interface {
	Selector() uint64
	HandleRequestResponse(context.Context, *RequestWrapper) (proto.Message, error)
}

type ServerRequestResponseHandler func(context.Context, *RequestWrapper) (proto.Message, error)

type ServerRequestResponseHandlerAsync func(context.Context, *RequestWrapper) *mo.Future[proto.Message]

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