forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-24 13:46:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Update api_server.go

Browse source
This commit is contained in:
Ocenka 2025-08-11 13:59:46 +01:00 committed by GitHub
parent 66bd4e0edd
commit ee6da02c40
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
beacon/light/api/api_server.go
View file

@ -26,7 +26,7 @@ import (
"github.com/ethereum/go-ethereum/log" "github.com/ethereum/go-ethereum/log"
) )
// ApiServer is a wrapper around BeaconLightApi that implements request.requestServer. // ApiServer is a wrapper around BeaconLightApi that implements request.Server.
type ApiServer struct { type ApiServer struct {
api *BeaconLightApi api *BeaconLightApi
eventCallback func(event request.Event) eventCallback func(event request.Event)
@ -38,7 +38,7 @@ func NewApiServer(api *BeaconLightApi) *ApiServer {
return &ApiServer{api: api} return &ApiServer{api: api}
} }
// Subscribe implements request.requestServer. // Subscribe implements request.Server.
func (s *ApiServer) Subscribe(eventCallback func(event request.Event)) { func (s *ApiServer) Subscribe(eventCallback func(event request.Event)) {
s.eventCallback = eventCallback s.eventCallback = eventCallback
listener := HeadEventListener{ listener := HeadEventListener{
@ -61,7 +61,7 @@ func (s *ApiServer) Subscribe(eventCallback func(event request.Event)) {
s.unsubscribe = s.api.StartHeadListener(listener) s.unsubscribe = s.api.StartHeadListener(listener)
} }
// SendRequest implements request.requestServer. // SendRequest implements request.Server.
func (s *ApiServer) SendRequest(id request.ID, req request.Request) { func (s *ApiServer) SendRequest(id request.ID, req request.Request) {
go func() { go func() {
var resp request.Response var resp request.Response
@ -99,7 +99,7 @@ func (s *ApiServer) SendRequest(id request.ID, req request.Request) {
}() }()
} }
// Unsubscribe implements request.requestServer. // Unsubscribe implements request.Server.
// Note: Unsubscribe should not be called concurrently with Subscribe. // Note: Unsubscribe should not be called concurrently with Subscribe.
func (s *ApiServer) Unsubscribe() { func (s *ApiServer) Unsubscribe() {
if s.unsubscribe != nil { if s.unsubscribe != nil {