forked from cerc-io/plugeth
parent
7307d97ae1
commit
f4ff4268f7
@ -186,7 +186,7 @@ func DialContext(ctx context.Context, rawurl string) (*Client, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Client retrieves the client from the context, if any. This can be used to perform
|
// ClientFromContext retrieves the client from the context, if any. This can be used to perform
|
||||||
// 'reverse calls' in a handler method.
|
// 'reverse calls' in a handler method.
|
||||||
func ClientFromContext(ctx context.Context) (*Client, bool) {
|
func ClientFromContext(ctx context.Context) (*Client, bool) {
|
||||||
client, ok := ctx.Value(clientContextKey{}).(*Client)
|
client, ok := ctx.Value(clientContextKey{}).(*Client)
|
||||||
@ -333,7 +333,7 @@ func (c *Client) BatchCall(b []BatchElem) error {
|
|||||||
return c.BatchCallContext(ctx, b)
|
return c.BatchCallContext(ctx, b)
|
||||||
}
|
}
|
||||||
|
|
||||||
// BatchCall sends all given requests as a single batch and waits for the server
|
// BatchCallContext sends all given requests as a single batch and waits for the server
|
||||||
// to return a response for all of them. The wait duration is bounded by the
|
// to return a response for all of them. The wait duration is bounded by the
|
||||||
// context's deadline.
|
// context's deadline.
|
||||||
//
|
//
|
||||||
|
@ -34,7 +34,7 @@ import (
|
|||||||
var (
|
var (
|
||||||
// ErrNotificationsUnsupported is returned when the connection doesn't support notifications
|
// ErrNotificationsUnsupported is returned when the connection doesn't support notifications
|
||||||
ErrNotificationsUnsupported = errors.New("notifications not supported")
|
ErrNotificationsUnsupported = errors.New("notifications not supported")
|
||||||
// ErrNotificationNotFound is returned when the notification for the given id is not found
|
// ErrSubscriptionNotFound is returned when the notification for the given id is not found
|
||||||
ErrSubscriptionNotFound = errors.New("subscription not found")
|
ErrSubscriptionNotFound = errors.New("subscription not found")
|
||||||
)
|
)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user