(req types.RequestBeginBlock)
| 363 | } |
| 364 | |
| 365 | func (cli *socketClient) BeginBlockSync(req types.RequestBeginBlock) (*types.ResponseBeginBlock, error) { |
| 366 | reqres := cli.queueRequest(types.ToRequestBeginBlock(req)) |
| 367 | if err := cli.FlushSync(); err != nil { |
| 368 | return nil, err |
| 369 | } |
| 370 | |
| 371 | return reqres.Response.GetBeginBlock(), cli.Error() |
| 372 | } |
| 373 | |
| 374 | func (cli *socketClient) EndBlockSync(req types.RequestEndBlock) (*types.ResponseEndBlock, error) { |
| 375 | reqres := cli.queueRequest(types.ToRequestEndBlock(req)) |
nothing calls this directly
no test coverage detected