diff options
Diffstat (limited to 'internal/server/handlers/basehandler.go')
| -rw-r--r-- | internal/server/handlers/basehandler.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/internal/server/handlers/basehandler.go b/internal/server/handlers/basehandler.go index a61da48..f21262e 100644 --- a/internal/server/handlers/basehandler.go +++ b/internal/server/handlers/basehandler.go @@ -366,3 +366,8 @@ func (h *baseHandler) GetTurboChannel() chan []byte { func (h *baseHandler) TurboChannelLen() int { return h.turbo.channelLen() } + +// WaitForTurboEOFAck waits until turbo reader acknowledges EOF or timeout. +func (h *baseHandler) WaitForTurboEOFAck(timeout time.Duration) bool { + return h.turbo.waitForEOFAck(timeout) +} |