Correct spelling for initiateStreaming() comment.

This commit is contained in:
dcadevil 2017-09-21 11:36:27 +08:00
parent 52f2dd7a20
commit 351bfe1a24

View File

@ -915,7 +915,7 @@ func (this *Migrator) printStatus(rule PrintStatusRule, writers ...io.Writer) {
}
}
// initiateStreaming begins treaming of binary log events and registers listeners for such events
// initiateStreaming begins streaming of binary log events and registers listeners for such events
func (this *Migrator) initiateStreaming() error {
this.eventsStreamer = NewEventsStreamer()
if err := this.eventsStreamer.InitDBConnections(); err != nil {