update servers

examples/main.go

@@ -24,16 +24,15 @@ func main() {
 
 	server.Of("/").OnConnect(func(s *sio.SocketV4) error {
 		log.Println("connected:", s.ID())
+		err := s.Join("test")
+		if err != nil {
+			panic(err)
+		}
 		s.On("notice", CustomWrap(func(a string) error {
-			return s.Emit("reply", seri.String("have "+a))
+			return s.To("test").Emit("reply", seri.String("have "+a))
 		}))
 		s.On("bye", CustomWrap(func(a string) error {
-			return s.Emit("bye", seri.String(a))
-			return nil
-		}))
-		s.Of("/chat").On("msg", CustomWrap(func(a string) error {
-			fmt.Println("Msg", a)
-			return s.Emit("bye", seri.String(a))
+			return s.To("test").Emit("bye", seri.String(a))
 			return nil
 		}))
 		return nil
@@ -41,6 +40,10 @@ func main() {
 
 	server.Of("/chat").OnConnect(func(s *sio.SocketV4) error {
 		log.Println("connected:", s.ID())
+		err := s.Join("test")
+		if err != nil {
+			panic(err)
+		}
 		s.On("msg", CustomWrap(func(a string) error {
 			server.In()
 			return s.Emit("msg", seri.String(a))

internal/readwriter/write.go

@@ -3,7 +3,7 @@ package readwriter
 import (
 	"bufio"
 	"io"
-	
+
 	errs "github.com/oarkflow/socketio/internal/errors"
 )
 
@@ -35,5 +35,5 @@ func NewWriter(w io.Writer) *Writer {
 	if ww, ok := w.(interface{ PropagateWriter() *Writer }); ok {
 		return ww.PropagateWriter()
 	}
-	return &Writer{w: bufio.NewWriter(w)}
+	return &Writer{w: bufio.NewWriterSize(w, 1e6)}
 }

internal/readwriter/write.method.go

@@ -3,7 +3,7 @@ package readwriter
 import (
 	"bufio"
 	"io"
-	
+
 	errs "github.com/oarkflow/socketio/internal/errors"
 )
 
@@ -11,7 +11,7 @@ func (wtr *Writer) Bytes(p []byte) wtrErr {
 	if wtr.err != nil {
 		return wtr
 	}
-	
+
 	_, wtr.err = wtr.w.Write(p)
 	return onWtrErr{wtr}
 }
@@ -20,7 +20,7 @@ func (wtr *Writer) Byte(p byte) wtrErr {
 	if wtr.err != nil {
 		return wtr
 	}
-	
+
 	wtr.err = wtr.w.WriteByte(p)
 	return onWtrErr{wtr}
 }
@@ -29,7 +29,7 @@ func (wtr *Writer) String(str string) wtrErr {
 	if wtr.err != nil {
 		return wtr
 	}
-	
+
 	return wtr.Bytes([]byte(str))
 }
 
@@ -41,7 +41,7 @@ func (wtr *Writer) To(w io.WriterTo) wtrErr {
 	if wtr.err != nil {
 		return wtr
 	}
-	
+
 	_, wtr.err = w.WriteTo(wtr.w)
 	return onWtrErr{wtr}
 }
@@ -50,8 +50,8 @@ func (wtr *Writer) Copy(src io.Reader) wtrErr {
 	if wtr.err != nil {
 		return wtr
 	}
-	
-	_, wtr.err = io.Copy(wtr.w, src)
+
+	_, wtr.err = wtr.w.ReadFrom(src)
 	return onWtrErr{wtr}
 }
 
@@ -59,7 +59,7 @@ func (wtr *Writer) Multi(ww ...io.Writer) *Writer {
 	if wtr.err != nil {
 		return wtr
 	}
-	
+
 	wtr.w = bufio.NewWriter(io.MultiWriter(append([]io.Writer{wtr.w}, ww...)...))
 	return wtr
 }