message-size-increase #3
@ -313,9 +313,6 @@ func (this *readerA) pull() (uint16, error) {
|
||||
this.eof = true
|
||||
}
|
||||
return message.method, nil
|
||||
} else {
|
||||
// signal parent transaction of closure
|
||||
this.parent.closed.Store(true)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user