asynchronous non-blocking read and write support

lxzan · Feb 25, 2023 · 73420c6 · 73420c6
1 parent 6351fe3
commit 73420c6
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 11 deletions.
diff --git a/Makefile b/Makefile
@@ -10,5 +10,5 @@ build:
 run-testsuite-server:
 	go run github.com/lxzan/gws/examples/testsuite
 
-coverage:
-	go test ./... -covermode=count -coverprofile=./bin/gws.out
+cover:
+	go test -coverprofile=./bin/cover.out --cover ./...
diff --git a/README.md b/README.md
@@ -27,7 +27,6 @@
 
 - [gws](#gws)
   - [Highlight](#highlight)
-  - [Attention](#attention)
   - [Benchmark](#benchmark)
   - [Core Interface](#core-interface)
   - [Install](#install)
@@ -42,14 +41,9 @@
 - zero extra goroutine to manage connection
 - zero error to read/write operation, errors have been handled appropriately
 - built-in concurrent_map implementation
-- support for asynchronous write messages
+- asynchronous non-blocking read and write support
 - fully passes the WebSocket [autobahn-testsuite](https://github.com/crossbario/autobahn-testsuite)
 
-#### Attention
-
-- It's designed for api server, not suitable for transmitting large messages.
-- WebSocket events are emitted synchronously, manage goroutines yourself.
-
 #### Benchmark
 
 - machine: Ubuntu 20.04LTS VM (4C8T)

diff --git a/aio.go b/aio.go
@@ -27,7 +27,6 @@ type (
 func newWorkerQueue(maxConcurrency int64) *workerQueue {
 	c := &workerQueue{
 		mu:             &sync.Mutex{},
-		q:              make([]asyncJob, 0),
 		maxConcurrency: maxConcurrency,
 		curConcurrency: 0,
 	}

diff --git a/examples/testsuite/main.go b/examples/testsuite/main.go
@@ -8,11 +8,11 @@ import (
 
 func main() {
 	var upgrader = gws.NewUpgrader(func(c *gws.Upgrader) {
+		c.EventHandler = new(WebSocket)
 		c.CompressEnabled = true
 		c.CheckTextEncoding = true
 		c.MaxContentLength = 32 * 1024 * 1024
 		c.AsyncReadEnabled = true
-		c.EventHandler = new(WebSocket)
 	})
 
 	http.HandleFunc("/connect", func(writer http.ResponseWriter, request *http.Request) {