add write buff drained callback

shaovie · Sep 22, 2023 · a4060b7 · a4060b7
1 parent 8cf505e
commit a4060b7
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/io_handle.go b/io_handle.go
@@ -178,6 +178,10 @@ func (h *IOHandle) Destroy(eh EvHandler) {
 	}
 }
 
+// OnWriteBufferDrained called by asyncWriteBufQ drained
+func (h *IOHandle) OnWriteBufferDrained() {
+}
+
 //
 //= EvHandler interface
 

diff --git a/io_handle_async.go b/io_handle_async.go
@@ -57,6 +57,7 @@ func (h *IOHandle) AsyncOrderedFlush(eh EvHandler) {
 	if h.asyncWriteBufQ.IsEmpty() {
 		h.ep.remove(fd, EvOut)
 		h.asyncWriteWaiting = false
+		h.OnWriteBufferDrained()
 	}
 }