bailing out from onApplyEventStruct()

Shlomi Noach · Shlomi Noach · commit baaa255182fa · 2017-01-04T12:42:21.000+02:00
diff --git a/go/logic/migrator.go b/go/logic/migrator.go
@@ -1074,7 +1074,9 @@ func (this *Migrator) executeWriteFuncs() error {
 		select {
 		case eventStruct := <-this.applyEventsQueue:
 			{
-				this.onApplyEventStruct(eventStruct)
+				if err := this.onApplyEventStruct(eventStruct); err != nil {
+					return err
+				}
 			}
 		default:
 			{

Original file line number	Diff line number	Diff line change
`@@ -1074,7 +1074,9 @@ func (this *Migrator) executeWriteFuncs() error {`
`1074`	`1074`	`select {`
`1075`	`1075`	`case eventStruct := <-this.applyEventsQueue:`
`1076`	`1076`	`{`
`1077`		`- this.onApplyEventStruct(eventStruct)`
	`1077`	`+ if err := this.onApplyEventStruct(eventStruct); err != nil {`
	`1078`	`+ return err`
	`1079`	`+ }`
`1078`	`1080`	`}`
`1079`	`1081`	`default:`
`1080`	`1082`	`{`