Skip to content
Open
9 changes: 0 additions & 9 deletions pkg/sources/forward/applier/sourcetransformer.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,12 +35,3 @@ type ApplySourceTransformFunc func(ctx context.Context, message *isb.ReadMessage
func (f ApplySourceTransformFunc) ApplyTransform(ctx context.Context, message *isb.ReadMessage) ([]*isb.WriteMessage, error) {
return f(ctx, message)
}

var (
// Terminal Applier do not make any change to the message
Terminal = ApplySourceTransformFunc(func(ctx context.Context, msg *isb.ReadMessage) ([]*isb.WriteMessage, error) {
return []*isb.WriteMessage{{
Message: msg.Message,
}}, nil
})
)
Loading