| 1425 | } |
| 1426 | |
| 1427 | static struct io_plan *rpc_conn_write_request(struct io_conn *conn, |
| 1428 | struct plugin *plugin) |
| 1429 | { |
| 1430 | struct jstream *jstr = list_top(&plugin->rpc_js_list, struct jstream, list); |
| 1431 | if (jstr) |
| 1432 | return json_stream_output(jstr->js, conn, |
| 1433 | rpc_stream_complete, plugin); |
| 1434 | |
| 1435 | return io_out_wait(conn, plugin->io_rpc_conn, |
| 1436 | rpc_conn_write_request, plugin); |
| 1437 | } |
| 1438 | |
| 1439 | static struct io_plan *rpc_conn_init(struct io_conn *conn, |
| 1440 | struct plugin *plugin) |
no outgoing calls
no test coverage detected