syncasync

type Bridge interface {
	// Init is required as there's a bi-directional relationship between sysmessaging and syncasync bridge
	Init(sysevents sysmessaging.SystemEvents)
	// Request performs a request/reply exchange taking a message as input, and returning a message as a response
	// The input message must have a tag, and a group, to be routed appropriately.
	RequestReply(ctx context.Context, ns string, send RequestSender) (*fftypes.MessageInOut, error)
	// SendConfirm blocks until the message is confirmed (or rejected), but does not look for a reply.
	SendConfirm(ctx context.Context, ns string, send RequestSender) (*fftypes.Message, error)
	// SendConfirmTokenPool blocks until the token pool is confirmed (or rejected)
	SendConfirmTokenPool(ctx context.Context, ns string, send RequestSender) (*fftypes.TokenPool, error)
	// SendConfirmTokenTransfer blocks until the token transfer is confirmed
	SendConfirmTokenTransfer(ctx context.Context, ns string, send RequestSender) (*fftypes.TokenTransfer, error)
}

type RequestSender func(requestID *fftypes.UUID) error