rate

Documentation

Index

• type RpcRateResolver
  • func NewResolver(converterService converter.Converter) *RpcRateResolver
  • func (r *RpcRateResolver) SubscribeRates(req *ferprpc.SubscribeRatesRequest, ...) error

Types

type RpcRateResolver

type RpcRateResolver struct {
	ConverterService converter.Converter
	Shutdown         context.CancelFunc
	// contains filtered or unexported fields
}

func NewResolver

func NewResolver(converterService converter.Converter) *RpcRateResolver

func (*RpcRateResolver) SubscribeRates

func (r *RpcRateResolver) SubscribeRates(req *ferprpc.SubscribeRatesRequest, stream ferprpc.RateService_SubscribeRatesServer) error