transport

type Handler interface {
	Serve(ctx context.Context, request *jsonrpc.Request, response *jsonrpc.Response)
	OnNotification(ctx context.Context, notification *jsonrpc.Notification)
}

type Interceptor interface {
	// Intercept is called after a response is received for a specific method (even if it's an error)
	// It receives the context, original request, and the response
	// If it returns a non-nil request, that request will be sent as a follow-up
	// If it returns nil, no additional request will be sent
	Intercept(ctx context.Context, request *jsonrpc.Request, response *jsonrpc.Response) (*jsonrpc.Request, error)
}

type NewHandler func(ctx context.Context, transport Transport) Handler

type Notifier interface {
	Notify(ctx context.Context, notification *jsonrpc.Notification) error
}

type RoundTrip struct {
	Request  *jsonrpc.Request
	Response *jsonrpc.Response
	// contains filtered or unexported fields
}

type RoundTrips struct {
	Ring []*RoundTrip
	// contains filtered or unexported fields
}

type Sequencer interface {
	NextRequestID() jsonrpc.RequestId

	// LastRequestID returns the most recently generated request id without
	// mutating the underlying sequence counter.
	LastRequestID() jsonrpc.RequestId
}

type Transport interface {
	Notifier
	Send(ctx context.Context, request *jsonrpc.Request) (*jsonrpc.Response, error)
}