ok

.gitignore

@@ -4,6 +4,6 @@
 *.tmp
 *.log
 *.test
-
 coverage.txt
 report.xml
+*.test.txt

contrib/extension/subscription/conn.go

@@ -9,14 +9,14 @@ import (
 type Conn interface {
 	Subscribe(ctx context.Context, namespace string, channel any, args any) (ClientSubscription, error)
 
-	jsonrpc.StreamingConn
+	jsonrpc.Conn
 }
 
 func UpgradeConn(c jsonrpc.Conn, err error) (Conn, error) {
 	if err != nil {
 		return nil, err
 	}
-	if val, ok := c.(jsonrpc.StreamingConn); ok {
+	if val, ok := c.(jsonrpc.Conn); ok {
 		engine := NewWrapClient(val)
 		val.Mount(engine.Middleware)
 		return engine, nil

pkg/jsonrpc/conn.go

@@ -7,6 +7,7 @@ import (
 
 type Conn interface {
 	Doer
+	Notifier
 	BatchCaller
 
 	Mounter
@@ -15,11 +16,6 @@ type Conn interface {
 	Closed() <-chan struct{}
 }
 
-type StreamingConn interface {
-	Conn
-	Notifier
-}
-
 type Doer interface {
 	Do(ctx context.Context, result any, method string, params any) error
 }
@@ -33,5 +29,5 @@ type Notifier interface {
 }
 
 type Mounter interface {
-	Mount(Middleware)
+	Mount(Handler)
 }