fix sending request header.
This commit is contained in:
2
relay.go
2
relay.go
@@ -62,7 +62,7 @@ func NewRelay(ctx context.Context, url string, opts RelayOptions) *Relay {
|
|||||||
okCallbacks: xsync.NewMapOf[ID, func(bool, string)](),
|
okCallbacks: xsync.NewMapOf[ID, func(bool, string)](),
|
||||||
writeQueue: make(chan writeRequest),
|
writeQueue: make(chan writeRequest),
|
||||||
subscriptionChannelCloseQueue: make(chan *Subscription),
|
subscriptionChannelCloseQueue: make(chan *Subscription),
|
||||||
requestHeader: nil,
|
requestHeader: opts.RequestHeader,
|
||||||
}
|
}
|
||||||
|
|
||||||
return r
|
return r
|
||||||
|
|||||||
Reference in New Issue
Block a user